Mason Chen created FLINK-32893:
----------------------------------
Summary: Make client.id configurable from KafkaSource
Key: FLINK-32893
URL: https://issues.apache.org/jira/browse/FLINK-32893
Project: Flink
Issue Type: Improvement
Affects Versions: 1.17.1
Reporter: Mason Chen
The client id is not strictly configurable from the KafkaSource because it
appends a configurable prefix and subtask information to avoid the mbean
conflict exception messages that are internal to the Kafka client.
However, various users reported that they need use this client.id for Kafka
quotas and they need to have control over the client.id to enforce quotas
properly.
Affects Kafka connector 3.1 and below.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
