This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 83fd46fbdbb864984e2d0134fa7151e1e5c13f77 Author: Fabian Paul <[email protected]> AuthorDate: Wed Sep 15 14:56:56 2021 +0200 [FLINK-24281][connectors/kafka] Only allow KafkaSinkBuilder creation with KafkaSink.builder() --- .../java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java index 678a48e..e87d4dd 100644 --- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java +++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java @@ -70,6 +70,8 @@ public class KafkaSinkBuilder<IN> { private KafkaRecordSerializationSchema<IN> recordSerializer; private String bootstrapServers; + KafkaSinkBuilder() {} + /** * Sets the wanted the {@link DeliveryGuarantee}. The default delivery guarantee is {@link * #deliveryGuarantee}.
