Class and Description |
---|
CommonKafkaSpoutConfig |
CommonKafkaSpoutConfig.Builder |
Class and Description |
---|
CommonKafkaSpoutConfig |
CommonKafkaSpoutConfig.Builder |
ConsumerFactory
This is here to enable testing.
|
OffsetManager
Manages acked and committed offsets for a TopicPartition.
|
Class and Description |
---|
OffsetManager
Manages acked and committed offsets for a TopicPartition.
|
Class and Description |
---|
CommonKafkaSpoutConfig |
CommonKafkaSpoutConfig.Builder |
Copyright © 2019 The Apache Software Foundation. All rights reserved.