[flink] create table validate options

apache · Aug 6, 2024 · 8aac48e · 8aac48e
1 parent 96f458c
commit 8aac48e
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java
@@ -351,7 +351,14 @@ private void validateOptions(Map<String, String> options) {
                         .collect(Collectors.toSet());
 
         Set<String> additionalValidOptions =
-                new HashSet<>(Arrays.asList("is_streaming", "connector", "log.system"));
+                new HashSet<>(
+                        Arrays.asList(
+                                "is_streaming",
+                                "connector",
+                                "log.system",
+                                "kafka.bootstrap.servers",
+                                "kafka.topic",
+                                "kafka.transaction.timeout.ms"));
 
         options.keySet()
                 .forEach(