Package org.apache.storm.kafka.monitor
Class KafkaOffsetLagUtil
java.lang.Object
org.apache.storm.kafka.monitor.KafkaOffsetLagUtil
Utility class for querying offset lag for kafka spout.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic List<KafkaOffsetLagResult>getOffsetLags(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery) Get offset lags.static void
- 
Constructor Details- 
KafkaOffsetLagUtilpublic KafkaOffsetLagUtil()
 
- 
- 
Method Details- 
main
- 
getOffsetLagspublic static List<KafkaOffsetLagResult> getOffsetLags(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery) throws Exception Get offset lags.- Parameters:
- newKafkaSpoutOffsetQuery- represents the information needed to query kafka for log head and spout offsets
- Returns:
- log head offset, spout offset and lag for each partition
- Throws:
- Exception
 
 
-