Interface | Description |
---|---|
ConsumerFactory<K,V> |
This is here to enable testing.
|
Class | Description |
---|---|
CommitMetadata |
Object representing metadata committed to Kafka.
|
CommitMetadataManager |
Generates and reads commit metadata.
|
CommonKafkaSpoutConfig<K,V> | |
CommonKafkaSpoutConfig.Builder<K,V,T extends CommonKafkaSpoutConfig.Builder<K,V,T>> | |
ConsumerFactoryDefault<K,V> | |
OffsetManager |
Manages acked and committed offsets for a TopicPartition.
|
Timer |
Copyright © 2023 The Apache Software Foundation. All rights reserved.