flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x
Date Tue, 08 Dec 2015 17:46:10 GMT
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)

Mime
View raw message