Package org.apache.storm.kafka.monitor
Class KafkaOffsetLagResult
java.lang.Object
org.apache.storm.kafka.monitor.KafkaOffsetLagResult
- All Implemented Interfaces:
net.minidev.json.JSONAware
Class representing the log head offsets, spout offsets and the lag for a topic.
-
Constructor Details
-
KafkaOffsetLagResult
public KafkaOffsetLagResult(String topic, int parition, long consumerCommittedOffset, long logHeadOffset)
-
-
Method Details
-
getTopic
-
getPartition
public int getPartition() -
getConsumerCommittedOffset
public long getConsumerCommittedOffset() -
getLogHeadOffset
public long getLogHeadOffset() -
getLag
public long getLag() -
toString
-
equals
-
hashCode
public int hashCode() -
toJSONString
- Specified by:
toJSONString
in interfacenet.minidev.json.JSONAware
-