[ 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)