| 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 © 2022 The Apache Software Foundation. All Rights Reserved.