[
https://issues.apache.org/jira/browse/FLINK-35404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Harshit Mittal updated FLINK-35404:
-----------------------------------
Description:
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.
was:Currently Kafka new source doesn't register metrics of KafkaConsumer in
KafkaPartitionSplitReader. These metrics should be added for debugging and
monitoring purpose.
> 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)
