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