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 and Description
KafkaTridentSpoutMigration()

Method Summary

Modifier and Type	Method and 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 Detail

KafkaTridentSpoutMigration

public KafkaTridentSpoutMigration()

Method Detail

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