Package | Description |
---|---|
org.apache.storm.kafka.monitor |
Class and Description |
---|
KafkaOffsetLagResult
Class representing the log head offsets, spout offsets and the lag for a topic.
|
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 © 2019 The Apache Software Foundation. All rights reserved.