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 © 2022 The Apache Software Foundation. All Rights Reserved.