Class | Description |
---|---|
KafkaTridentSpoutBatchMetadata |
Wraps transaction batch information
|
KafkaTridentSpoutEmitter<K,V> | |
KafkaTridentSpoutManager<K,V> | |
KafkaTridentSpoutOpaque<K,V> | |
KafkaTridentSpoutOpaqueCoordinator<K,V> | |
KafkaTridentSpoutTopicPartition |
ISpoutPartition that wraps TopicPartition information |
KafkaTridentSpoutTransactional | |
TopicPartitionSerializer |
Enum | Description |
---|---|
KafkaTridentSpoutTopicPartitionRegistry |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.