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()) {