flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback
Date Thu, 29 Jun 2017 08:26:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067986#comment-16067986
] 

ASF GitHub Bot commented on FLINK-6998:
---------------------------------------

Github user tzulitai commented on the issue:

    https://github.com/apache/flink/pull/4187
  
    > I'll not include the other proposed metric in this PR just for the sake of simplicity.
I also have some opinions on "offset lag" metric, I think this particular metric is more useful
when some external entity
    perform the monitoring (difference of committed offset vs log head), especially in failure
situations.
    
    Yes, lets keep that apart from this PR. There is also a JIRA for exactly this feature:
https://issues.apache.org/jira/browse/FLINK-6109


> 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)

Mime
View raw message