[hotfix][docs] Fix scan.bounded.mode missing forward options

apache · Oct 13, 2023 · 81a49a1 · 81a49a1
1 parent b09928d
commit 81a49a1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/docs/content/docs/connectors/table/kafka.md b/docs/content/docs/connectors/table/kafka.md
@@ -337,6 +337,7 @@ Connector Options
     <tr>
       <td><h5>scan.bounded.mode</h5></td>
       <td>optional</td>
+      <td>yes</td>
       <td style="word-wrap: break-word;">unbounded</td>
       <td>Enum</td>
       <td>Bounded mode for Kafka consumer, valid values are <code>'latest-offset'</code>, <code>'group-offsets'</code>, <code>'timestamp'</code> and <code>'specific-offsets'</code>.

diff --git a/...main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java b/...main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java
@@ -168,7 +168,10 @@ public Set<ConfigOption<?>> forwardOptions() {
                         SCAN_STARTUP_TIMESTAMP_MILLIS,
                         SINK_PARTITIONER,
                         SINK_PARALLELISM,
-                        TRANSACTIONAL_ID_PREFIX)
+                        TRANSACTIONAL_ID_PREFIX,
+                        SCAN_BOUNDED_MODE,
+                        SCAN_BOUNDED_SPECIFIC_OFFSETS,
+                        SCAN_BOUNDED_TIMESTAMP_MILLIS)
                 .collect(Collectors.toSet());
     }