From adbfac4c4497d565e234954b87d94867c1417f39 Mon Sep 17 00:00:00 2001
From: wujuan <wujuan@dtstack.com>
Date: Tue, 2 Dec 2025 10:38:06 +0800
Subject: [PATCH] [hotfix-#1960][kafka] KafkaSyncConverter construct parameter
 transmission error

---
 .../chunjun/connector/kafka/source/KafkaSourceFactory.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source/KafkaSourceFactory.java b/chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source/KafkaSourceFactory.java
index b91405daad..2281872031 100644
--- a/chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source/KafkaSourceFactory.java
+++ b/chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source/KafkaSourceFactory.java
@@ -118,8 +118,7 @@ public DataStream<RowData> createSource() {
         RowType rowType =
                 TableUtil.createRowType(kafkaConfig.getColumn(), KafkaRawTypeMapping::apply);
         DynamicKafkaDeserializationSchema deserializationSchema =
-                new RowDeserializationSchema(
-                        kafkaConfig, new KafkaSyncConverter(rowType, kafkaConfig));
+                new RowDeserializationSchema(kafkaConfig, new KafkaSyncConverter(kafkaConfig));
         KafkaConsumerWrapper consumer =
                 new KafkaConsumerWrapper(topics, deserializationSchema, props);
         switch (kafkaConfig.getMode()) {