Package org.apache.storm.kafka.migration

Class KafkaTridentSpoutMigration

java.lang.Object

org.apache.storm.kafka.migration.KafkaTridentSpoutMigration

public class KafkaTridentSpoutMigration
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaTridentSpoutMigration()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	Migrates offsets from the Zookeeper store used by the storm-kafka Trident spouts, to the Zookeeper store used by the storm-kafka-clients Trident spout.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaTridentSpoutMigration

public KafkaTridentSpoutMigration()

Method Details

main

public static void main(String[] args)
                 throws Exception

Migrates offsets from the Zookeeper store used by the storm-kafka Trident spouts, to the Zookeeper store used by the storm-kafka-clients Trident spout.

Throws:

Exception