Package org.apache.storm.kafka.monitor
Class KafkaPartitionOffsetLag
java.lang.Object
org.apache.storm.kafka.monitor.KafkaPartitionOffsetLag
-
Constructor Details
-
KafkaPartitionOffsetLag
public KafkaPartitionOffsetLag(long consumerCommittedOffset, long logHeadOffset)
-
-
Method Details