You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2021/09/17 13:19:55 UTC
[flink] 02/03: [FLINK-24281][connectors/kafka] Only allow
KafkaSinkBuilder creation with KafkaSink.builder()
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 <fa...@ververica.com>
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}.