You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/08 18:46:10 UTC
[jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a
metric in the web interface for Kafka 0.8.x
Robert Metzger created FLINK-3146:
-------------------------------------
Summary: Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x
Key: FLINK-3146
URL: https://issues.apache.org/jira/browse/FLINK-3146
Project: Flink
Issue Type: Improvement
Components: Kafka Connector
Reporter: Robert Metzger
Right now the Kafka consumer is not reporting any metrics to the web frontend.
For the Kafka 0.9.0.0 I'll probably use the metrics reported by Kafka, for Kafka 0.8. we need to manually request the current ("latest") offset and compare it to the last read offset.
I've added this JIRA to see how many Flink users are interested in this. If you want this feature, please comment into the JIRA!
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)