Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35404

Report metrics of KafkaConsumer in new Kafka source

    XMLWordPrintableJSON

Details

    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.

       

      Attachments

        Issue Links

          is a clone of

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-22766 Report metrics of KafkaConsumer in Kafka new source

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #103

          Activity

            People

              renqs Qingsheng Ren
              hmittal83 Harshit Mittal
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: