Uses of Class
org.apache.storm.kafka.monitor.NewKafkaSpoutOffsetQuery
Packages that use NewKafkaSpoutOffsetQuery
-
Uses of NewKafkaSpoutOffsetQuery in org.apache.storm.kafka.monitor
Methods in org.apache.storm.kafka.monitor with parameters of type NewKafkaSpoutOffsetQueryModifier and TypeMethodDescriptionstatic List<KafkaOffsetLagResult>KafkaOffsetLagUtil.getOffsetLags(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery) Get offset lags.