[
https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15308350#comment-15308350
]
ASF GitHub Bot commented on STORM-1136:
---------------------------------------
Github user priyank5485 commented on the pull request:
https://github.com/apache/storm/pull/1451
@harshach Will do that. Just to confirm, you mean the section header in UI
under Topology Stats, right? Also, since the topology can technically have more
than one kafka spout and we are showing lags for all spouts there I was
thinking of keeping it as plural. May be Kafka Spouts Lag
Does that sound okay?
> Provide a bin script to check consumer lag from KafkaSpout to Kafka topic
> offsets
> ---------------------------------------------------------------------------------
>
> Key: STORM-1136
> URL: https://issues.apache.org/jira/browse/STORM-1136
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-kafka
> Reporter: Sriharsha Chintalapani
> Assignee: Priyank Shah
>
> We store kafkaspout offsets in zkroot + id path in zookeeper. Kafka provides
> a utility and a protocol request to fetch latest offsets into topic
> {code}
> example:
> bin/kafka-run-classh.sh kafka.tools.GetOffsetTool
> {code}
> we should provide a way for the user to check how far the kafka spout read
> into topic and whats the lag. If we can expose this via UI even better.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
