fix

yuzelin · Nov 14, 2023 · e69527a · e69527a
1 parent 7d339eb
commit e69527a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...link-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java b/...link-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java
@@ -51,7 +51,7 @@ protected String topic() {
 
     @Override
     protected MessageQueueSchemaUtils.ConsumerWrapper consumer(String topic) {
-        return KafkaActionUtils.getKafkaEarliestConsumer(mqConfig, topic, primaryKeys);
+        return KafkaActionUtils.getKafkaEarliestConsumer(mqConfig, topic);
     }
 
     @Override