| Class | Description |
|---|---|
| KafkaOffsetLagResult |
Class representing the log head offsets, spout offsets and the lag for a topic.
|
| KafkaOffsetLagUtil |
Utility class for querying offset lag for kafka spout.
|
| KafkaPartitionOffsetLag | |
| NewKafkaSpoutOffsetQuery |
Class representing information for querying kafka for log head offsets, consumer offsets and the difference for new kafka spout using new consumer api.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.