[ https://issues.apache.org/jira/browse/FLINK-32893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17755707#comment-17755707 ]
Mason Chen commented on FLINK-32893: ------------------------------------ I was talking to [~ryanvanhuuksloot] offline, he's interested in picking this up > 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 > Priority: Major > > 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)