Package | Description |
---|---|
org.apache.storm.kafka.spout.internal | |
org.apache.storm.kafka.spout.trident |
Class and Description |
---|
KafkaConsumerFactory
This is here to enable testing
|
OffsetManager
Manages acked and committed offsets for a TopicPartition.
|
Class and Description |
---|
Timer |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.