Uses of Package
org.apache.storm.kafka.monitor
-
ClassDescriptionClass representing the log head offsets, spout offsets and the lag for a topic.Class representing information for querying kafka for log head offsets, consumer offsets and the difference for new kafka spout using new consumer api.