[FLINK-27174] Non-null check for bootstrapServers field is incorrect in KafkaSink

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.4, 1.15.0, 1.16.0
• Fix Version/s: 1.14.5, 1.15.1, 1.16.0
• Component/s: Connectors / Kafka
• Labels: easyfix pull-request-available
• Assignee: Zhengqi Zhang
• Reporter: Zhengqi Zhang
• Created: 11/Apr/22 10:24
• Updated: 24/May/22 11:43
• Resolved: 24/May/22 11:43

Description

If the user-supplied kafkaProducerConfig contains bootstrapServers information, there is no need to define the value of this field separately through the setBootstrapServers method. Obviously, the current code doesn't notice this.

 

Perhaps we can check bootstrapServers as follows:

 

Or check bootstrapServers like KafkaSourceBuilder.

 

 

Issue Links

• links to: GitHub Pull Request #19628