[
https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722601#comment-17722601
]
Yaroslav Tkachenko commented on FLINK-28842:
--------------------------------------------
Hi Valentina, unfortunately I didn’t have a chance to address feedback, so feel
free to provide an alternative PR.
> 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
> Assignee: Yaroslav Tkachenko
> Priority: Major
> Labels: pull-request-available
>
> 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)
