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 <claus.ib...@gmail.com> 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;