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

Kafka consumer's offset metrics are not registered for dynamically discovered partitions

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      Currently, the per-partition offset metrics are registered via the AbstractFetcher#addOffsetStateGauge method. That method is only ever called for the initial startup partitions, and not for dynamically discovered partitions.

      We should consider adding some unit tests to make sure that metrics are properly registered for all partitions. That would also safeguard us from accidentally removing metrics.

        Attachments

          Activity

            People

            • Assignee:
              tzulitai Tzu-Li (Gordon) Tai
              Reporter:
              tzulitai Tzu-Li (Gordon) Tai

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment