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
|
OldKafkaSpoutOffsetQuery |
Class representing information for querying kafka for log head offsets, spout offsets and the difference for old kafka spout
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.