Uses of Class
org.apache.storm.kafka.monitor.NewKafkaSpoutOffsetQuery
-
Uses of NewKafkaSpoutOffsetQuery in org.apache.storm.kafka.monitor
Modifier and TypeMethodDescriptionstatic List<KafkaOffsetLagResult>
KafkaOffsetLagUtil.getOffsetLags
(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery) Get offset lags.