| Class | Description |
|---|---|
| TridentKafkaClientTopologyNamedTopics |
This example sets up a few topologies to put random strings in Kafka topics via the KafkaBolt, and shows how to set up a Trident topology that reads from some Kafka topics using the KafkaSpout.
|
| TridentKafkaClientTopologyWildcardTopics |
This example is similar to
TridentKafkaClientTopologyWildcardTopics, but demonstrates subscribing to Kafka topics with a regex. |
| TridentKafkaConsumerTopology | |
| TridentKafkaState<K,V> | |
| TridentKafkaStateFactory<K,V> | |
| TridentKafkaStateUpdater<K,V> |
Copyright © 2021 The Apache Software Foundation. All rights reserved.