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)