[
https://issues.apache.org/jira/browse/FLINK-35404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847993#comment-17847993
]
Harshit Mittal edited comment on FLINK-35404 at 5/20/24 8:55 PM:
-----------------------------------------------------------------
A better way to solve this problem is to implement interface `MetricsReporter`
from kafka metrics using a MetricGroup from apache-flink.
was (Author: hmittal83):
A better way to solve this problem is to implement KafkaMetrics reporter
interface using a MetricGroup from apache-flink.
> Report metrics of KafkaConsumer in new Kafka source
> ---------------------------------------------------
>
> Key: FLINK-35404
> URL: https://issues.apache.org/jira/browse/FLINK-35404
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Affects Versions: 1.13.0
> Reporter: Harshit Mittal
> Assignee: Qingsheng Ren
> Priority: Major
> Labels: pull-request-available
>
> Currently new Kafka source only registers metrics that are available on
> KafkaPartitionSplitReader initialization. However, there are metrics added
> later in the lifecycle like consumer lag metrics that are missing from the
> KafkaConsumer metric group.
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
