Package org.apache.storm.kafka.migration
Class KafkaTridentSpoutMigration
java.lang.Object
org.apache.storm.kafka.migration.KafkaTridentSpoutMigration
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
KafkaTridentSpoutMigrationpublic KafkaTridentSpoutMigration()
 
- 
- 
Method Details- 
mainMigrates 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
 
 
-