Class KafkaTridentSpoutMigration

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

public class KafkaTridentSpoutMigration extends Object
  • 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