Skip to content

Commit 60bc4eb

Browse files
authored
[hotfix-#1960][kafka] KafkaSyncConverter construct parameter transmission error (#1961)
1 parent d6dc136 commit 60bc4eb

File tree

1 file changed

+1
-2
lines changed
  • chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source

1 file changed

+1
-2
lines changed

chunjun-connectors/chunjun-connector-kafka/src/main/java/com/dtstack/chunjun/connector/kafka/source/KafkaSourceFactory.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,8 +118,7 @@ public DataStream<RowData> createSource() {
118118
RowType rowType =
119119
TableUtil.createRowType(kafkaConfig.getColumn(), KafkaRawTypeMapping::apply);
120120
DynamicKafkaDeserializationSchema deserializationSchema =
121-
new RowDeserializationSchema(
122-
kafkaConfig, new KafkaSyncConverter(rowType, kafkaConfig));
121+
new RowDeserializationSchema(kafkaConfig, new KafkaSyncConverter(kafkaConfig));
123122
KafkaConsumerWrapper consumer =
124123
new KafkaConsumerWrapper(topics, deserializationSchema, props);
125124
switch (kafkaConfig.getMode()) {

0 commit comments

Comments
 (0)