fix

yuzelin · Dec 1, 2023 · cb74ab7 · cb74ab7
1 parent 2e3d0f2
commit cb74ab7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java b/...rc/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java
@@ -44,7 +44,7 @@ public String identifier() {
 
     @Override
     public Optional<Action> create(MultipleParameterToolAdapter params) {
-        checkRequiredArgument(params, "kafka-conf");
+        checkRequiredArgument(params, KAFKA_CONF);
 
         KafkaSyncDatabaseAction action =
                 new KafkaSyncDatabaseAction(