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