KafkaTridentSpoutMigration (Storm 2.7.1 API)

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

public class KafkaTridentSpoutMigration
extends Object

Constructor Summary

Constructors
Constructor Description

KafkaTridentSpoutMigration()

Method Summary

All Methods Static Methods Concrete Methods
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 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