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

Posted to dev@flink.apache.org by "Yaroslav Tkachenko (Jira)" <ji...@apache.org> on 2022/08/05 21:00:00 UTC

[jira] [Created] (FLINK-28842) Add client.id.prefix for the KafkaSink

Yaroslav Tkachenko created FLINK-28842:
------------------------------------------

             Summary: Add client.id.prefix for the KafkaSink
                 Key: FLINK-28842
                 URL: https://issues.apache.org/jira/browse/FLINK-28842
             Project: Flink
          Issue Type: New Feature
          Components: Connectors / Kafka
    Affects Versions: 1.15.1
            Reporter: Yaroslav Tkachenko


Currently, KafkaSink doesn't provide a way to configure a client.id.prefix like KafkaSource does. client.id is as important for Kafka Producers, so it makes sense to implement the missing logic for the KafkaSink. 

A similar implementation that leverages subtaskId for uniqueness can be used here.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)