loserwang1024 opened a new pull request, #156: URL: https://github.com/apache/flink-connector-kafka/pull/156
As described in https://issues.apache.org/jira/browse/FLINK-37380 , though org.apache.flink.connector.kafka.sink.KafkaSinkBuilder#sanityCheck said "EXACTLY_ONCE delivery guarantee requires a transactionIdPrefix to be set to provide **unique transaction names across multiple KafkaSinks writing to the same Kafka cluster**., it 's no use because the transactionalIdPrefix with a default value "kafka-sink" will never be null. This PR just remove the default value, and make the sanityCheck valid. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
