You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@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)