Regen

catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/master.json

@@ -25,8 +25,10 @@
   "componentProperties": {
     "bridgeErrorHandler": { "index": 0, "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. Important: This is only possible if the 3rd party component allows Camel to be alerted if an exception was thrown. Some components handle this internally only, and therefore bridgeErrorHandler is not possible. In other situations we may improve the Camel component to hook into the 3rd party component and make this possible for future releases. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored." },
     "autowiredEnabled": { "index": 1, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which then gets configured on the component. This can be used for automatic configuring JDBC data sources, JMS connection factories, AWS Clients, etc." },
-    "service": { "index": 2, "kind": "property", "displayName": "Service", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.cluster.CamelClusterService", "deprecated": false, "autowired": false, "secret": false, "description": "Inject the service to use." },
-    "serviceSelector": { "index": 3, "kind": "property", "displayName": "Service Selector", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.cluster.CamelClusterService.Selector", "deprecated": false, "autowired": false, "secret": false, "description": "Inject the service selector used to lookup the CamelClusterService to use." }
+    "backOffDelay": { "index": 2, "kind": "property", "displayName": "Back Off Delay", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "description": "When the master becomes leader then backoff is in use to repeat starting the consumer until the consumer is successfully started or max attempts reached. This option is the delay in millis between start attempts." },
+    "backOffMaxAttempts": { "index": 3, "kind": "property", "displayName": "Back Off Max Attempts", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "description": "When the master becomes leader then backoff is in use to repeat starting the consumer until the consumer is successfully started or max attempts reached. This option is the maximum number of attempts to try." },
+    "service": { "index": 4, "kind": "property", "displayName": "Service", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.cluster.CamelClusterService", "deprecated": false, "autowired": false, "secret": false, "description": "Inject the service to use." },
+    "serviceSelector": { "index": 5, "kind": "property", "displayName": "Service Selector", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.cluster.CamelClusterService.Selector", "deprecated": false, "autowired": false, "secret": false, "description": "Inject the service selector used to lookup the CamelClusterService to use." }
   },
   "properties": {
     "namespace": { "index": 0, "kind": "path", "displayName": "Namespace", "group": "consumer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cluster namespace to use" },

components-starter/camel-debezium-db2-starter/src/main/docs/debezium-db2.json

@@ -33,6 +33,20 @@
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
       "defaultValue": false
     },
+    {
+      "name": "camel.component.debezium-db2.cdc-change-tables-schema",
+      "type": "java.lang.String",
+      "description": "The name of the schema where CDC change tables are located; defaults to 'ASNCDC'",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+      "defaultValue": "ASNCDC"
+    },
+    {
+      "name": "camel.component.debezium-db2.cdc-control-schema",
+      "type": "java.lang.String",
+      "description": "The name of the schema where CDC control structures are located; defaults to 'ASNCDC'",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+      "defaultValue": "ASNCDC"
+    },
     {
       "name": "camel.component.debezium-db2.column-exclude-list",
       "type": "java.lang.String",
@@ -111,6 +125,13 @@
       "description": "A comma-separated list of regular expressions matching the database-specific data type names that adds the data type's original type and original length as parameters to the corresponding field schemas in the emitted change records.",
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
     },
+    {
+      "name": "camel.component.debezium-db2.db2-platform",
+      "type": "java.lang.String",
+      "description": "Informs connector which Db2 implementation platform it is connected to. The default is 'LUW', which means Windows, UNIX, Linux. Using a value of 'Z' ensures that the Db2 for z\/OS specific SQL statements are used.",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+      "defaultValue": "LUW"
+    },
     {
       "name": "camel.component.debezium-db2.decimal-handling-mode",
       "type": "java.lang.String",
@@ -473,6 +494,13 @@
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
       "defaultValue": "io.debezium.connector.db2.Db2SourceInfoStructMaker"
     },
+    {
+      "name": "camel.component.debezium-db2.streaming-delay-ms",
+      "type": "java.lang.Long",
+      "description": "A delay period after the snapshot is completed and the streaming begins, given in milliseconds. Defaults to 0 ms. The option is a long type.",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+      "defaultValue": 0
+    },
     {
       "name": "camel.component.debezium-db2.table-exclude-list",
       "type": "java.lang.String",
@@ -518,6 +546,13 @@
       "type": "java.lang.String",
       "description": "Topic prefix that identifies and provides a namespace for the particular database server\/cluster is capturing changes. The topic prefix should be unique across all other connectors, since it is used as a prefix for all Kafka topic names that receive events emitted by this connector. Only alphanumeric characters, hyphens, dots and underscores must be accepted.",
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+    },
+    {
+      "name": "camel.component.debezium-db2.transaction-metadata-factory",
+      "type": "java.lang.String",
+      "description": "Class to make transaction context & transaction struct\/schemas",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+      "defaultValue": "io.debezium.pipeline.txmetadata.DefaultTransactionMetadataFactory"
     }
   ],
   "hints": []

components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConfiguration.java

@@ -128,6 +128,16 @@ public class DebeziumDb2ComponentConfiguration
      * etc.
      */
     private Boolean autowiredEnabled = true;
+    /**
+     * The name of the schema where CDC change tables are located; defaults to
+     * 'ASNCDC'
+     */
+    private String cdcChangeTablesSchema = "ASNCDC";
+    /**
+     * The name of the schema where CDC control structures are located; defaults
+     * to 'ASNCDC'
+     */
+    private String cdcControlSchema = "ASNCDC";
     /**
      * Regular expressions matching columns to exclude from change events
      */
@@ -183,6 +193,12 @@ public class DebeziumDb2ComponentConfiguration
      * the emitted change records.
      */
     private String datatypePropagateSourceType;
+    /**
+     * Informs connector which Db2 implementation platform it is connected to.
+     * The default is 'LUW', which means Windows, UNIX, Linux. Using a value of
+     * 'Z' ensures that the Db2 for z/OS specific SQL statements are used.
+     */
+    private String db2Platform = "LUW";
     /**
      * Specify how DECIMAL and NUMERIC columns should be represented in change
      * events, including: 'precise' (the default) uses java.math.BigDecimal to
@@ -456,6 +472,11 @@ public class DebeziumDb2ComponentConfiguration
      * schema and struct.
      */
     private String sourceinfoStructMaker = "io.debezium.connector.db2.Db2SourceInfoStructMaker";
+    /**
+     * A delay period after the snapshot is completed and the streaming begins,
+     * given in milliseconds. Defaults to 0 ms. The option is a long type.
+     */
+    private Long streamingDelayMs = 0L;
     /**
      * A comma-separated list of regular expressions that match the
      * fully-qualified names of tables to be excluded from monitoring
@@ -502,6 +523,10 @@ public class DebeziumDb2ComponentConfiguration
      * alphanumeric characters, hyphens, dots and underscores must be accepted.
      */
     private String topicPrefix;
+    /**
+     * Class to make transaction context & transaction struct/schemas
+     */
+    private String transactionMetadataFactory = "io.debezium.pipeline.txmetadata.DefaultTransactionMetadataFactory";
 
     public Map<String, Object> getAdditionalProperties() {
         return additionalProperties;
@@ -617,6 +642,22 @@ public void setAutowiredEnabled(Boolean autowiredEnabled) {
         this.autowiredEnabled = autowiredEnabled;
     }
 
+    public String getCdcChangeTablesSchema() {
+        return cdcChangeTablesSchema;
+    }
+
+    public void setCdcChangeTablesSchema(String cdcChangeTablesSchema) {
+        this.cdcChangeTablesSchema = cdcChangeTablesSchema;
+    }
+
+    public String getCdcControlSchema() {
+        return cdcControlSchema;
+    }
+
+    public void setCdcControlSchema(String cdcControlSchema) {
+        this.cdcControlSchema = cdcControlSchema;
+    }
+
     public String getColumnExcludeList() {
         return columnExcludeList;
     }
@@ -706,6 +747,14 @@ public void setDatatypePropagateSourceType(
         this.datatypePropagateSourceType = datatypePropagateSourceType;
     }
 
+    public String getDb2Platform() {
+        return db2Platform;
+    }
+
+    public void setDb2Platform(String db2Platform) {
+        this.db2Platform = db2Platform;
+    }
+
     public String getDecimalHandlingMode() {
         return decimalHandlingMode;
     }
@@ -1067,6 +1116,14 @@ public void setSourceinfoStructMaker(String sourceinfoStructMaker) {
         this.sourceinfoStructMaker = sourceinfoStructMaker;
     }
 
+    public Long getStreamingDelayMs() {
+        return streamingDelayMs;
+    }
+
+    public void setStreamingDelayMs(Long streamingDelayMs) {
+        this.streamingDelayMs = streamingDelayMs;
+    }
+
     public String getTableExcludeList() {
         return tableExcludeList;
     }
@@ -1122,4 +1179,12 @@ public String getTopicPrefix() {
     public void setTopicPrefix(String topicPrefix) {
         this.topicPrefix = topicPrefix;
     }
+
+    public String getTransactionMetadataFactory() {
+        return transactionMetadataFactory;
+    }
+
+    public void setTransactionMetadataFactory(String transactionMetadataFactory) {
+        this.transactionMetadataFactory = transactionMetadataFactory;
+    }
 }

components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb.json

@@ -479,6 +479,13 @@
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration",
       "defaultValue": "io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker"
     },
+    {
+      "name": "camel.component.debezium-mongodb.streaming-delay-ms",
+      "type": "java.lang.Long",
+      "description": "A delay period after the snapshot is completed and the streaming begins, given in milliseconds. Defaults to 0 ms. The option is a long type.",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration",
+      "defaultValue": 0
+    },
     {
       "name": "camel.component.debezium-mongodb.tombstones-on-delete",
       "type": "java.lang.Boolean",
@@ -498,6 +505,13 @@
       "type": "java.lang.String",
       "description": "Topic prefix that identifies and provides a namespace for the particular database server\/cluster is capturing changes. The topic prefix should be unique across all other connectors, since it is used as a prefix for all Kafka topic names that receive events emitted by this connector. Only alphanumeric characters, hyphens, dots and underscores must be accepted.",
       "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration"
+    },
+    {
+      "name": "camel.component.debezium-mongodb.transaction-metadata-factory",
+      "type": "java.lang.String",
+      "description": "Class to make transaction context & transaction struct\/schemas",
+      "sourceType": "org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration",
+      "defaultValue": "io.debezium.pipeline.txmetadata.DefaultTransactionMetadataFactory"
     }
   ],
   "hints": []

components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java

@@ -437,6 +437,11 @@ public class DebeziumMongodbComponentConfiguration
      * schema and struct.
      */
     private String sourceinfoStructMaker = "io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker";
+    /**
+     * A delay period after the snapshot is completed and the streaming begins,
+     * given in milliseconds. Defaults to 0 ms. The option is a long type.
+     */
+    private Long streamingDelayMs = 0L;
     /**
      * Whether delete operations should be represented by a delete event and a
      * subsequent tombstone event (true) or only by a delete event (false).
@@ -459,6 +464,10 @@ public class DebeziumMongodbComponentConfiguration
      * alphanumeric characters, hyphens, dots and underscores must be accepted.
      */
     private String topicPrefix;
+    /**
+     * Class to make transaction context & transaction struct/schemas
+     */
+    private String transactionMetadataFactory = "io.debezium.pipeline.txmetadata.DefaultTransactionMetadataFactory";
 
     public Map<String, Object> getAdditionalProperties() {
         return additionalProperties;
@@ -1029,6 +1038,14 @@ public void setSourceinfoStructMaker(String sourceinfoStructMaker) {
         this.sourceinfoStructMaker = sourceinfoStructMaker;
     }
 
+    public Long getStreamingDelayMs() {
+        return streamingDelayMs;
+    }
+
+    public void setStreamingDelayMs(Long streamingDelayMs) {
+        this.streamingDelayMs = streamingDelayMs;
+    }
+
     public Boolean getTombstonesOnDelete() {
         return tombstonesOnDelete;
     }
@@ -1052,4 +1069,12 @@ public String getTopicPrefix() {
     public void setTopicPrefix(String topicPrefix) {
         this.topicPrefix = topicPrefix;
     }
+
+    public String getTransactionMetadataFactory() {
+        return transactionMetadataFactory;
+    }
+
+    public void setTransactionMetadataFactory(String transactionMetadataFactory) {
+        this.transactionMetadataFactory = transactionMetadataFactory;
+    }
 }