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

Posted to dev@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/05/03 08:20:00 UTC

[jira] [Created] (FLINK-27480) KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning

Fabian Paul created FLINK-27480:
-----------------------------------

             Summary: KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning
                 Key: FLINK-27480
                 URL: https://issues.apache.org/jira/browse/FLINK-27480
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
    Affects Versions: 1.14.4, 1.15.0, 1.16.0
            Reporter: Fabian Paul


More and more frequently, users ran into an issue by not correctly configuring the KafkaSource ([https://stackoverflow.com/questions/72026997/flink-instancealreadyexistsexception-while-migrating-to-the-kafkasource)] and setting non-distinguishable groupIds for the source. Internally the used KafkaConsumer tries to register with the metric system and incorporates the groupId as part of the metric, leading to name collision.

We should update the documentation to explain the situation properly.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)