This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 78a42522883 Regen
78a42522883 is described below
commit 78a42522883b6a45f0c94772d4b2b334501b5c25
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Apr 26 12:09:43 2025 +0200
Regen
---
.../dsl/DebeziumSqlserverComponentBuilderFactory.java | 19 +++++++++++++++++++
1 file changed, 19 insertions(+)
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index 61048f7ad1b..59ec5115da6 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -1545,6 +1545,24 @@ public interface
DebeziumSqlserverComponentBuilderFactory {
return this;
}
+ /**
+ * Specifies the maximum number of rows that should be read in one go
+ * from each table while streaming. The connector will read the table
+ * contents in multiple batches of this size. Defaults to 0 which means
+ * no limit.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param streamingFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder streamingFetchSize(int
streamingFetchSize) {
+ doSetProperty("streamingFetchSize", streamingFetchSize);
+ return this;
+ }
+
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1794,6 +1812,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "streamingDelayMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setStreamingDelayMs((long) value); return true;
+ case "streamingFetchSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setStreamingFetchSize((int) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIncludeList((java.lang.String) value); return true;