You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/01/12 01:46:00 UTC

[jira] [Created] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

Tzu-Li (Gordon) Tai created FLINK-8419:
------------------------------------------

             Summary: Kafka consumer's offset metrics are not registered for dynamically discovered partitions
                 Key: FLINK-8419
                 URL: https://issues.apache.org/jira/browse/FLINK-8419
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector, Metrics
    Affects Versions: 1.4.0, 1.5.0
            Reporter: Tzu-Li (Gordon) Tai
            Assignee: Tzu-Li (Gordon) Tai
            Priority: Blocker
             Fix For: 1.5.0, 1.4.1


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.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)