commit f76370603b1b38b88bcbf69e830e0c3a8132b7ca
author Fabian Paul <fabianpaul@ververica.com> Tue Sep 14 14:29:07 2021 +0200
committer Robert Metzger <89049+rmetzger@users.noreply.github.com> Fri Sep 17 15:17:59 2021 +0200
tree aea2300b97d2a5d5183a708482ec9e33c9f47679
parent 8debdd06be0e917610c50a77893f7ade45cee98f

[hotfix][connectors/kafka] Remove unused code from KafkaDynamicSink

flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java

diff --git a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java
index 1fd9caf..a67472b 100644
--- a/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java
+++ b/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java
@@ -27,7 +27,6 @@
 import org.apache.flink.connector.kafka.sink.KafkaSink;
 import org.apache.flink.connector.kafka.sink.KafkaSinkBuilder;
 import org.apache.flink.streaming.api.datastream.DataStreamSink;
-import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;
 import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaPartitioner;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.connector.ChangelogMode;
@@ -359,20 +358,6 @@
         return metadataKeys.size() > 0;
     }
 
-    private static FlinkKafkaProducer.Semantic getSemantic(DeliveryGuarantee deliveryGuarantee) {
-        switch (deliveryGuarantee) {
-            case NONE:
-                return FlinkKafkaProducer.Semantic.NONE;
-            case AT_LEAST_ONCE:
-                return FlinkKafkaProducer.Semantic.AT_LEAST_ONCE;
-            case EXACTLY_ONCE:
-                return FlinkKafkaProducer.Semantic.EXACTLY_ONCE;
-            default:
-                throw new IllegalStateException(
-                        "Unsupported delivery guarantee " + deliveryGuarantee);
-        }
-    }
-
     private RowData.FieldGetter[] getFieldGetters(
             List<LogicalType> physicalChildren, int[] keyProjection) {
         return Arrays.stream(keyProjection)