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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic List<KafkaOffsetLagResult>
getOffsetLags
(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery) Get offset lags.static void
-
Constructor Details
-
KafkaOffsetLagUtil
public KafkaOffsetLagUtil()
-
-
Method Details
-
main
-
getOffsetLags
public 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
-