[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066180#comment-16066180
]
ASF GitHub Bot commented on FLINK-6998:
---------------------------------------
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4187
I don't think it matters to much whether a metric is completely measured by
Flink or just forwarded from kafka classes. Having "kafka" in the name also
introduces an inherent redundancy, since the scope for, say the
KafkaConsumerThread, already contains "KafkaConsumer".
> Kafka connector needs to expose metrics for failed/successful offset commits
> in the Kafka Consumer callback
> -----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-6998
> URL: https://issues.apache.org/jira/browse/FLINK-6998
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Zhenzhong Xu
> Assignee: Zhenzhong Xu
>
> Propose to add "kafkaCommitsSucceeded" and "kafkaCommitsFailed" metrics in
> KafkaConsumerThread class.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
