flink-connector-kafka
flink-connector-kafka copied to clipboard
[FLINK-28842] add client.id.prefix for kafka sink
https://issues.apache.org/jira/browse/FLINK-28842
fix javax.management.InstanceAlreadyExistsException
for kafka sink
similar to https://github.com/apache/flink-connector-kafka/pull/118 and address the producer pool comments