[ https://issues.apache.org/jira/browse/FLINK-28842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576047#comment-17576047 ]
Yaroslav Tkachenko commented on FLINK-28842: -------------------------------------------- I believe this will also fix https://issues.apache.org/jira/browse/FLINK-8093 > 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 > Priority: Major > > 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)