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)
