Package org.apache.storm.kafka.monitor
Class NewKafkaSpoutOffsetQuery
java.lang.Object
org.apache.storm.kafka.monitor.NewKafkaSpoutOffsetQuery
Class representing information for querying kafka for log head offsets, consumer offsets and the difference for new
kafka spout using new consumer api.
-
Constructor Details
-
NewKafkaSpoutOffsetQuery
-
-
Method Details