You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Mason Chen (Jira)" <ji...@apache.org> on 2023/08/17 21:35:00 UTC

[jira] [Created] (FLINK-32893) Make client.id configurable from KafkaSource

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)