[flink-table-store] branch master updated: [hotfix] Remove transaction set in KafkaLogSinkProvider

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d738f23 [hotfix] Remove transaction set in KafkaLogSinkProvider
9d738f23 is described below

commit 9d738f23588d1b260bd7c03050a8f16518c1712e
Author: Jingsong Lee <jingsongl...@gmail.com>
AuthorDate: Thu Dec 8 18:14:25 2022 +0800

    [hotfix] Remove transaction set in KafkaLogSinkProvider
    
    This closes #427
---
 .../java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java  | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
 
b/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
index 67194214..bc71952b 100644
--- 
a/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
+++ 
b/flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogSinkProvider.java
@@ -27,8 +27,6 @@ import 
org.apache.flink.table.store.CoreOptions.LogConsistency;
 import org.apache.flink.table.store.log.LogSinkProvider;
 import org.apache.flink.table.store.table.sink.LogSinkFunction;
 
-import org.apache.kafka.clients.producer.ProducerConfig;
-
 import javax.annotation.Nullable;
 
 import java.util.Properties;
@@ -70,7 +68,6 @@ public class KafkaLogSinkProvider implements LogSinkProvider {
         Semantic semantic;
         switch (consistency) {
             case TRANSACTIONAL:
-                properties.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, 
"log-store-" + topic);
                 semantic = Semantic.EXACTLY_ONCE;
                 break;
             case EVENTUAL: