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: &lt;code&gt;int&lt;/code&gt; 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;

Reply via email to