| Interface | Description |
|---|---|
| IBatchCoordinator | |
| IBrokerReader |
| Class | Description |
|---|---|
| DefaultCoordinator | |
| DrpcResultsPrinter | |
| GlobalPartitionInformation | |
| KafkaProducerTopology | |
| LocalSubmitter | |
| MaxMetric | |
| OpaqueTridentKafkaSpout | Deprecated
storm-kafka has been deprecated and will be removed in a future Storm release.
|
| StaticBrokerReader | |
| TransactionalTridentKafkaSpout | Deprecated
storm-kafka has been deprecated and will be removed in a future Storm release.
|
| TridentKafkaClientWordCountNamedTopics | |
| TridentKafkaClientWordCountWildcardTopics | |
| TridentKafkaConfig | |
| TridentKafkaConsumerTopology | |
| TridentKafkaEmitter | |
| TridentKafkaState | Deprecated
storm-kafka has been deprecated and will be removed in a future Storm release.
|
| TridentKafkaStateFactory | |
| TridentKafkaStateUpdater<K,V> | |
| TridentKafkaTopology | |
| TridentKafkaUpdater | |
| TridentKafkaWordCount |
A sample word count trident topology using transactional kafka spout that has the following components.
|
| ZkBrokerReader |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.