fix comments

sd4324530 · sd4324530 · commit 7ffcbff0e1f1 · 2026-04-07T15:28:02.000+08:00
Signed-off-by: Pei Yu &lt;125331682@qq.com&gt;
diff --git a/docs/content.zh/docs/connectors/flink-sources/db2-cdc.md b/docs/content.zh/docs/connectors/flink-sources/db2-cdc.md
@@ -280,7 +280,8 @@ Db2 server.
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md
@@ -353,7 +353,8 @@ MongoDB 的更改事件记录在消息之前没有更新。因此，我们只能
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
@@ -460,7 +460,8 @@ Flink SQL> SELECT * FROM orders;
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md b/docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md
@@ -474,7 +474,8 @@ Flink SQL> SELECT * FROM orders;
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md b/docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md
@@ -460,7 +460,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md b/docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md
@@ -298,7 +298,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md b/docs/content.zh/docs/connectors/flink-sources/sqlserver-cdc.md
@@ -269,7 +269,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md b/docs/content.zh/docs/connectors/pipeline-connectors/mysql.md
@@ -368,7 +368,8 @@ pipeline:
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md b/docs/content.zh/docs/connectors/pipeline-connectors/oracle.md
@@ -275,7 +275,8 @@ pipeline:
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md b/docs/content.zh/docs/connectors/pipeline-connectors/postgres.md
@@ -300,7 +300,8 @@ pipeline:
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        每秒处理的最大数据量，默认值：-1，无限制。(只适用于flink2.x)
+        每秒发出的最大记录数，默认值为 -1，表示不进行速率限制。（仅适用于 flink 2.x）<br>
+        警告：增量/二进制日志阶段：速率限制可能导致连接器落后于上游变更流，在连接器赶上之前，二进制日志/WAL 可能会被清除（MySQL 数据丢失，PostgreSQL 复制槽问题）。
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/db2-cdc.md b/docs/content/docs/connectors/flink-sources/db2-cdc.md
@@ -280,7 +280,8 @@ Db2 server.
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/mongodb-cdc.md b/docs/content/docs/connectors/flink-sources/mongodb-cdc.md
@@ -378,7 +378,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/mysql-cdc.md b/docs/content/docs/connectors/flink-sources/mysql-cdc.md
@@ -474,7 +474,8 @@ Only valid for cdc 1.x version. During a snapshot operation, the connector will
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/oceanbase-cdc.md b/docs/content/docs/connectors/flink-sources/oceanbase-cdc.md
@@ -492,7 +492,8 @@ During a snapshot operation, the connector will query each included table to pro
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/oracle-cdc.md b/docs/content/docs/connectors/flink-sources/oracle-cdc.md
@@ -461,7 +461,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/postgres-cdc.md b/docs/content/docs/connectors/flink-sources/postgres-cdc.md
@@ -295,7 +295,8 @@ SELECT * FROM shipments;
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/flink-sources/sqlserver-cdc.md b/docs/content/docs/connectors/flink-sources/sqlserver-cdc.md
@@ -269,7 +269,8 @@ Connector Options
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/pipeline-connectors/mysql.md b/docs/content/docs/connectors/pipeline-connectors/mysql.md
@@ -377,7 +377,8 @@ pipeline:
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/pipeline-connectors/oracle.md b/docs/content/docs/connectors/pipeline-connectors/oracle.md
@@ -282,7 +282,8 @@ The max retry times that the connector should retry to build oracle database ser
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/docs/content/docs/connectors/pipeline-connectors/postgres.md b/docs/content/docs/connectors/pipeline-connectors/postgres.md
@@ -292,7 +292,8 @@ pipeline:
       <td style="word-wrap: break-word;">true</td>
       <td>Double</td>
       <td>
-        The maximum size of data processed per second, the default value: -1, not limited.(only for flink2.x)
+        The maximum number of records emitted per second, the default value: -1, means no rate limiting.(only for flink2.x)<br>
+        WARNING: Incremental/binlog phase: Rate limiting can cause the connector to fall behind the upstream change stream, risking binlog/WAL purging before the connector catches up (data loss for MySQL, replication slot issues for PostgreSQL).
       </td>
     </tr>
     </tbody>
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java
@@ -336,5 +336,5 @@ public class MySqlDataSourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 }
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oracle/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleDataSourceOptions.java
@@ -213,7 +213,7 @@ public class OracleDataSourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 
     public static Map<String, String> getPropertiesByPrefix(
             Configuration tableOptions, String prefix) {
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDataSourceOptions.java
@@ -287,5 +287,5 @@ public class PostgresDataSourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 }
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/JdbcSourceOptions.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/JdbcSourceOptions.java
@@ -116,5 +116,5 @@ public class JdbcSourceOptions extends SourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 }
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java
@@ -218,6 +218,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED);
+        options.add(RECORDS_PER_SECOND);
         return options;
     }
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java
@@ -184,5 +184,5 @@ public class MongoDBSourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 }
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java
@@ -262,6 +262,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP);
         options.add(SCAN_NEWLY_ADDED_TABLE_ENABLED);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED);
+        options.add(RECORDS_PER_SECOND);
         return options;
     }
 }
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java
@@ -298,5 +298,5 @@ public class MySqlSourceOptions {
                     .doubleType()
                     .defaultValue(-1d)
                     .withDescription(
-                            "The maximum size of data processed per second, the default value: -1, not limited");
+                            "The maximum number of records emitted per second, the default value: -1, means no rate limiting.");
 }
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java
@@ -209,6 +209,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(MySqlSourceOptions.USE_LEGACY_JSON_FORMAT);
         options.add(MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST);
         options.add(MySqlSourceOptions.SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED);
+        options.add(MySqlSourceOptions.RECORDS_PER_SECOND);
         return options;
     }
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java
@@ -198,6 +198,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP);
         options.add(SCAN_NEWLY_ADDED_TABLE_ENABLED);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED);
+        options.add(RECORDS_PER_SECOND);
         return options;
     }
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java
@@ -219,6 +219,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED);
         options.add(SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED);
         options.add(SCAN_INCLUDE_PARTITIONED_TABLES_ENABLED);
+        options.add(RECORDS_PER_SECOND);
         return options;
     }
 
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java
@@ -219,6 +219,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP);
         options.add(SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED);
+        options.add(RECORDS_PER_SECOND);
         return options;
     }
 
