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)
