Class KafkaSpoutMigration

java.lang.Object
org.apache.storm.kafka.migration.KafkaSpoutMigration

public class KafkaSpoutMigration extends Object
  • Constructor Details

    • KafkaSpoutMigration

      public KafkaSpoutMigration()
  • Method Details

    • main

      public static void main(String[] args) throws Exception
      Migrates offsets from the Zookeeper store used by the storm-kafka non-Trident spouts, to Kafka's offset store used by the storm-kafka-client non-Trident spout.
      Throws:
      Exception