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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 23aad9ec9bd "CAMEL-17091:camel-debezium-db2-starter" (#501)
23aad9ec9bd is described below
commit 23aad9ec9bd3285528797ae61e57171e9671ec8e
Author: Ramu <kramu...@gmail.com>
AuthorDate: Tue Apr 5 10:53:21 2022 +0530
"CAMEL-17091:camel-debezium-db2-starter" (#501)
Co-authored-by: Kodanda Ramu Kakarla <kkaka...@kkakarla.pnq.csb>
---
.../camel-debezium-db2-starter/pom.xml | 48 ++
.../src/main/docs/debezium-db2.json | 329 ++++++++++
.../DebeziumDb2ComponentAutoConfiguration.java | 79 +++
.../DebeziumDb2ComponentConfiguration.java | 691 +++++++++++++++++++++
.../springboot/DebeziumDb2ComponentConverter.java | 65 ++
.../src/main/resources/META-INF/LICENSE.txt | 203 ++++++
.../src/main/resources/META-INF/NOTICE.txt | 11 +
.../src/main/resources/META-INF/spring.factories | 21 +
.../src/main/resources/META-INF/spring.provides | 17 +
9 files changed, 1464 insertions(+)
diff --git a/components-starter/camel-debezium-db2-starter/pom.xml
b/components-starter/camel-debezium-db2-starter/pom.xml
new file mode 100644
index 00000000000..43593d9bb80
--- /dev/null
+++ b/components-starter/camel-debezium-db2-starter/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>components-starter</artifactId>
+ <version>3.17.0-SNAPSHOT</version>
+ </parent>
+ <artifactId>camel-debezium-db2-starter</artifactId>
+ <packaging>jar</packaging>
+ <!-- <name>Camel SB Starters :: Name Here</name>-->
+ <dependencies>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter</artifactId>
+ <version>${spring-boot-version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-debezium-db2</artifactId>
+ <version>${camel-version}</version>
+ </dependency>
+ <!--START OF GENERATED CODE-->
+ <dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-core-starter</artifactId>
+ </dependency>
+ <!--END OF GENERATED CODE-->
+ </dependencies>
+</project>
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/docs/debezium-db2.json
b/components-starter/camel-debezium-db2-starter/src/main/docs/debezium-db2.json
new file mode 100644
index 00000000000..89e63f4261c
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/docs/debezium-db2.json
@@ -0,0 +1,329 @@
+{
+ "groups": [
+ {
+ "name": "camel.component.debezium-db2",
+ "type":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.customizer",
+ "type":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "sourceMethod": "getCustomizer()"
+ }
+ ],
+ "properties": [
+ {
+ "name": "camel.component.debezium-db2.additional-properties",
+ "type": "java.util.Map<java.lang.String,java.lang.Object>",
+ "description": "Additional properties for debezium components in case
they can't be set directly on the camel configurations (e.g: setting Kafka
Connect properties needed by Debezium engine, for example setting
KafkaOffsetBackingStore), the properties have to be prefixed with
additionalProperties.. E.g:
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http:\/\/localhost:8811\/avro",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.autowired-enabled",
+ "type": "java.lang.Boolean",
+ "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.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": true
+ },
+ {
+ "name": "camel.component.debezium-db2.bridge-error-handler",
+ "type": "java.lang.Boolean",
+ "description": "Allows for bridging the consumer to the Camel routing
Error Handler, which mean any exceptions occurred while the consumer is trying
to pickup incoming messages, or the likes, will now be processed as a message
and handled by the routing Error Handler. 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.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": false
+ },
+ {
+ "name": "camel.component.debezium-db2.column-blacklist",
+ "type": "java.lang.String",
+ "description": "Regular expressions matching columns to exclude from
change events (deprecated, use column.exclude.list instead)",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.column-exclude-list",
+ "type": "java.lang.String",
+ "description": "Regular expressions matching columns to exclude from
change events",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.configuration",
+ "type":
"org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration",
+ "description": "Allow pre-configured Configurations to be set. The
option is a
org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration
type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.customizer.enabled",
+ "type": "java.lang.Boolean",
+ "sourceType":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-dbname",
+ "type": "java.lang.String",
+ "description": "The name of the database from which the connector should
capture changes",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-history",
+ "type": "java.lang.String",
+ "description": "The name of the DatabaseHistory class that should be
used to store and recover database schema changes. The configuration properties
for the history are prefixed with the 'database.history.' string.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "class
io.debezium.relational.history.KafkaDatabaseHistory"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-history-file-filename",
+ "type": "java.lang.String",
+ "description": "The path to the file that will be used to record the
database history",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name":
"camel.component.debezium-db2.database-history-kafka-bootstrap-servers",
+ "type": "java.lang.String",
+ "description": "A list of host\/port pairs that the connector will use
for establishing the initial connection to the Kafka cluster for retrieving
database schema history previously stored by the connector. This should point
to the same Kafka cluster used by the Kafka Connect process.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name":
"camel.component.debezium-db2.database-history-kafka-recovery-attempts",
+ "type": "java.lang.Integer",
+ "description": "The number of attempts in a row that no data are
returned from Kafka before recover completes. The maximum amount of time to
wait after receiving no data is (recovery.attempts) x
(recovery.poll.interval.ms).",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 100
+ },
+ {
+ "name":
"camel.component.debezium-db2.database-history-kafka-recovery-poll-interval-ms",
+ "type": "java.lang.Integer",
+ "description": "The number of milliseconds to wait while polling for
persisted data during recovery. The option is a int type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 100
+ },
+ {
+ "name": "camel.component.debezium-db2.database-history-kafka-topic",
+ "type": "java.lang.String",
+ "description": "The name of the topic for the database schema history",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-hostname",
+ "type": "java.lang.String",
+ "description": "Resolvable hostname or IP address of the database
server.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-password",
+ "type": "java.lang.String",
+ "description": "Password of the database user to be used when connecting
to the database.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-port",
+ "type": "java.lang.Integer",
+ "description": "Port of the database server.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 50000
+ },
+ {
+ "name": "camel.component.debezium-db2.database-server-name",
+ "type": "java.lang.String",
+ "description": "Unique name that identifies the database server and all
recorded offsets, and that is used as a prefix for all schemas and topics. Each
distinct installation should have a separate namespace and be monitored by at
most one Debezium connector.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.database-user",
+ "type": "java.lang.String",
+ "description": "Name of the database user to be used when connecting to
the database.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.decimal-handling-mode",
+ "type": "java.lang.String",
+ "description": "Specify how DECIMAL and NUMERIC columns should be
represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in consumers.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "precise"
+ },
+ {
+ "name": "camel.component.debezium-db2.enabled",
+ "type": "java.lang.Boolean",
+ "description": "Whether to enable auto configuration of the debezium-db2
component. This is enabled by default.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name":
"camel.component.debezium-db2.event-processing-failure-handling-mode",
+ "type": "java.lang.String",
+ "description": "Specify how failures during processing of events (i.e.
when encountering a corrupted event) should be handled, including:'fail' (the
default) an exception indicating the problematic event and its position is
raised, causing the connector to be stopped; 'warn' the problematic event and
its position will be logged and the event will be skipped;'ignore' the
problematic event will be skipped.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "fail"
+ },
+ {
+ "name": "camel.component.debezium-db2.heartbeat-interval-ms",
+ "type": "java.lang.Integer",
+ "description": "Length of an interval in milli-seconds in in which the
connector periodically sends heartbeat messages to a heartbeat topic. Use 0 to
disable heartbeat messages. Disabled by default. The option is a int type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 0
+ },
+ {
+ "name": "camel.component.debezium-db2.heartbeat-topics-prefix",
+ "type": "java.lang.String",
+ "description": "The prefix that is used to name heartbeat
topics.Defaults to __debezium-heartbeat.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "__debezium-heartbeat"
+ },
+ {
+ "name": "camel.component.debezium-db2.internal-key-converter",
+ "type": "java.lang.String",
+ "description": "The Converter class that should be used to serialize and
deserialize key data for offsets. The default is JSON converter.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "org.apache.kafka.connect.json.JsonConverter"
+ },
+ {
+ "name": "camel.component.debezium-db2.internal-value-converter",
+ "type": "java.lang.String",
+ "description": "The Converter class that should be used to serialize and
deserialize value data for offsets. The default is JSON converter.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "org.apache.kafka.connect.json.JsonConverter"
+ },
+ {
+ "name": "camel.component.debezium-db2.max-batch-size",
+ "type": "java.lang.Integer",
+ "description": "Maximum size of each batch of source records. Defaults
to 2048.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 2048
+ },
+ {
+ "name": "camel.component.debezium-db2.max-queue-size",
+ "type": "java.lang.Integer",
+ "description": "Maximum size of the queue for change events read from
the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 8192
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-commit-policy",
+ "type": "java.lang.String",
+ "description": "The name of the Java class of the commit policy. It
defines when offsets commit has to be triggered based on the number of events
processed and the time elapsed since the last commit. This class must implement
the interface 'OffsetCommitPolicy'. The default is a periodic commit policy
based upon time intervals.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue":
"io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy"
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-commit-timeout-ms",
+ "type": "java.lang.Long",
+ "description": "Maximum number of milliseconds to wait for records to
flush and partition offset data to be committed to offset storage before
cancelling the process and restoring the offset data to be committed in a
future attempt. The default is 5 seconds. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 5000
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-flush-interval-ms",
+ "type": "java.lang.Long",
+ "description": "Interval at which to try committing offsets. The default
is 1 minute. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 60000
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-storage",
+ "type": "java.lang.String",
+ "description": "The name of the Java class that is responsible for
persistence of connector offsets.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "org.apache.kafka.connect.storage.FileOffsetBackingStore"
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-storage-file-name",
+ "type": "java.lang.String",
+ "description": "Path to file where offsets are to be stored. Required
when offset.storage is set to the FileOffsetBackingStore.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-storage-partitions",
+ "type": "java.lang.Integer",
+ "description": "The number of partitions used when creating the offset
storage topic. Required when offset.storage is set to the
'KafkaOffsetBackingStore'.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-storage-replication-factor",
+ "type": "java.lang.Integer",
+ "description": "Replication factor used when creating the offset storage
topic. Required when offset.storage is set to the KafkaOffsetBackingStore",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.offset-storage-topic",
+ "type": "java.lang.String",
+ "description": "The name of the Kafka topic where offsets are to be
stored. Required when offset.storage is set to the KafkaOffsetBackingStore.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.poll-interval-ms",
+ "type": "java.lang.Long",
+ "description": "Time to wait for new change events to appear after
receiving no events, given in milliseconds. Defaults to 500 ms. The option is a
long type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": 500
+ },
+ {
+ "name": "camel.component.debezium-db2.snapshot-delay-ms",
+ "type": "java.lang.Long",
+ "description": "A delay period before a snapshot will begin, 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.snapshot-fetch-size",
+ "type": "java.lang.Integer",
+ "description": "The maximum number of records that should be loaded into
memory while performing a snapshot",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.snapshot-mode",
+ "type": "java.lang.String",
+ "description": "The criteria for running a snapshot upon startup of the
connector. Options include: 'initial' (the default) to specify the connector
should run a snapshot only when no offsets are available for the logical server
name; 'schema_only' to specify the connector should run a snapshot of the
schema when no offsets are available for the logical server name.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "initial"
+ },
+ {
+ "name":
"camel.component.debezium-db2.snapshot-select-statement-overrides",
+ "type": "java.lang.String",
+ "description": "This property contains a comma-separated list of
fully-qualified tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME),
depending on thespecific connectors. Select statements for the individual
tables are specified in further configuration properties, one for each table,
identified by the id 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME'
or 'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', respectively.
The value of those properties is the se [...]
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.source-struct-version",
+ "type": "java.lang.String",
+ "description": "A version of the format of the publicly visible source
part in the message",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "v2"
+ },
+ {
+ "name": "camel.component.debezium-db2.table-blacklist",
+ "type": "java.lang.String",
+ "description": "A comma-separated list of regular expressions that match
the fully-qualified names of tables to be excluded from monitoring (deprecated,
use table.exclude.list instead)",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.table-exclude-list",
+ "type": "java.lang.String",
+ "description": "A comma-separated list of regular expressions that match
the fully-qualified names of tables to be excluded from monitoring",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.table-ignore-builtin",
+ "type": "java.lang.Boolean",
+ "description": "Flag specifying whether built-in tables should be
ignored.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": true
+ },
+ {
+ "name": "camel.component.debezium-db2.table-include-list",
+ "type": "java.lang.String",
+ "description": "The tables for which changes are to be captured",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.table-whitelist",
+ "type": "java.lang.String",
+ "description": "The tables for which changes are to be captured
(deprecated, use table.include.list instead)",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration"
+ },
+ {
+ "name": "camel.component.debezium-db2.time-precision-mode",
+ "type": "java.lang.String",
+ "description": "Time, date, and timestamps can be represented with
different kinds of precisions, including:'adaptive' (the default) bases the
precision of time, date, and timestamp values on the database column's
precision; 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields
always use microseconds precision;'connect' always represents time, date, and
timestamp values using Kafka Connect's built-in representations for Time, Date,
and Timestamp, which uses millisecon [...]
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConfiguration",
+ "defaultValue": "adaptive"
+ }
+ ],
+ "hints": []
+}
\ No newline at end of file
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentAutoConfiguration.java
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentAutoConfiguration.java
new file mode 100644
index 00000000000..70310068aa4
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentAutoConfiguration.java
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.debezium.springboot;
+
+import javax.annotation.Generated;
+import org.apache.camel.CamelContext;
+import org.apache.camel.Component;
+import org.apache.camel.component.debezium.DebeziumDb2Component;
+import org.apache.camel.spi.ComponentCustomizer;
+import org.apache.camel.spring.boot.CamelAutoConfiguration;
+import org.apache.camel.spring.boot.ComponentConfigurationProperties;
+import org.apache.camel.spring.boot.util.CamelPropertiesHelper;
+import
org.apache.camel.spring.boot.util.ConditionalOnCamelContextAndAutoConfigurationBeans;
+import org.apache.camel.spring.boot.util.ConditionalOnHierarchicalProperties;
+import org.apache.camel.spring.boot.util.HierarchicalPropertiesEvaluator;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import
org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Conditional;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@Configuration(proxyBeanMethods = false)
+@Conditional(ConditionalOnCamelContextAndAutoConfigurationBeans.class)
+@EnableConfigurationProperties({ComponentConfigurationProperties.class,DebeziumDb2ComponentConfiguration.class})
+@ConditionalOnHierarchicalProperties({"camel.component",
"camel.component.debezium-db2"})
+@AutoConfigureAfter({CamelAutoConfiguration.class,
DebeziumDb2ComponentConverter.class})
+public class DebeziumDb2ComponentAutoConfiguration {
+
+ @Autowired
+ private ApplicationContext applicationContext;
+ private final CamelContext camelContext;
+ @Autowired
+ private DebeziumDb2ComponentConfiguration configuration;
+
+ public DebeziumDb2ComponentAutoConfiguration(
+ org.apache.camel.CamelContext camelContext) {
+ this.camelContext = camelContext;
+ }
+
+ @Lazy
+ @Bean
+ public ComponentCustomizer configureDebeziumDb2Component() {
+ return new ComponentCustomizer() {
+ @Override
+ public void configure(String name, Component target) {
+ CamelPropertiesHelper.copyProperties(camelContext,
configuration, target);
+ }
+ @Override
+ public boolean isEnabled(String name, Component target) {
+ return HierarchicalPropertiesEvaluator.evaluate(
+ applicationContext,
+ "camel.component.customizer",
+ "camel.component.debezium-db2.customizer")
+ && target instanceof DebeziumDb2Component;
+ }
+ };
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConfiguration.java
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConfiguration.java
new file mode 100644
index 00000000000..1c98cb03589
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConfiguration.java
@@ -0,0 +1,691 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.debezium.springboot;
+
+import java.util.Map;
+import javax.annotation.Generated;
+import
org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration;
+import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * Capture changes from a Oracle database.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@ConfigurationProperties(prefix = "camel.component.debezium-db2")
+public class DebeziumDb2ComponentConfiguration
+ extends
+ ComponentConfigurationPropertiesCommon {
+
+ /**
+ * Whether to enable auto configuration of the debezium-db2 component. This
+ * is enabled by default.
+ */
+ private Boolean enabled;
+ /**
+ * Additional properties for debezium components in case they can't be set
+ * directly on the camel configurations (e.g: setting Kafka Connect
+ * properties needed by Debezium engine, for example setting
+ * KafkaOffsetBackingStore), the properties have to be prefixed with
+ * additionalProperties.. E.g:
+ *
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=http://localhost:8811/avro
+ */
+ private Map<String, Object> additionalProperties;
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
pickup
+ * incoming messages, or the likes, will now be processed as a message and
+ * handled by the routing Error Handler. 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.
+ */
+ private Boolean bridgeErrorHandler = false;
+ /**
+ * Allow pre-configured Configurations to be set. The option is a
+ *
org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration
type.
+ */
+ private Db2ConnectorEmbeddedDebeziumConfiguration configuration;
+ /**
+ * The Converter class that should be used to serialize and deserialize key
+ * data for offsets. The default is JSON converter.
+ */
+ private String internalKeyConverter =
"org.apache.kafka.connect.json.JsonConverter";
+ /**
+ * The Converter class that should be used to serialize and deserialize
+ * value data for offsets. The default is JSON converter.
+ */
+ private String internalValueConverter =
"org.apache.kafka.connect.json.JsonConverter";
+ /**
+ * The name of the Java class of the commit policy. It defines when offsets
+ * commit has to be triggered based on the number of events processed and
+ * the time elapsed since the last commit. This class must implement the
+ * interface 'OffsetCommitPolicy'. The default is a periodic commit policy
+ * based upon time intervals.
+ */
+ private String offsetCommitPolicy =
"io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy";
+ /**
+ * Maximum number of milliseconds to wait for records to flush and
partition
+ * offset data to be committed to offset storage before cancelling the
+ * process and restoring the offset data to be committed in a future
+ * attempt. The default is 5 seconds. The option is a long type.
+ */
+ private Long offsetCommitTimeoutMs = 5000L;
+ /**
+ * Interval at which to try committing offsets. The default is 1 minute.
The
+ * option is a long type.
+ */
+ private Long offsetFlushIntervalMs = 60000L;
+ /**
+ * The name of the Java class that is responsible for persistence of
+ * connector offsets.
+ */
+ private String offsetStorage =
"org.apache.kafka.connect.storage.FileOffsetBackingStore";
+ /**
+ * Path to file where offsets are to be stored. Required when
offset.storage
+ * is set to the FileOffsetBackingStore.
+ */
+ private String offsetStorageFileName;
+ /**
+ * The number of partitions used when creating the offset storage topic.
+ * Required when offset.storage is set to the 'KafkaOffsetBackingStore'.
+ */
+ private Integer offsetStoragePartitions;
+ /**
+ * Replication factor used when creating the offset storage topic. Required
+ * when offset.storage is set to the KafkaOffsetBackingStore
+ */
+ private Integer offsetStorageReplicationFactor;
+ /**
+ * The name of the Kafka topic where offsets are to be stored. Required
when
+ * offset.storage is set to the KafkaOffsetBackingStore.
+ */
+ private String offsetStorageTopic;
+ /**
+ * 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.
+ */
+ private Boolean autowiredEnabled = true;
+ /**
+ * Regular expressions matching columns to exclude from change events
+ * (deprecated, use column.exclude.list instead)
+ */
+ private String columnBlacklist;
+ /**
+ * Regular expressions matching columns to exclude from change events
+ */
+ private String columnExcludeList;
+ /**
+ * The name of the database from which the connector should capture changes
+ */
+ private String databaseDbname;
+ /**
+ * The name of the DatabaseHistory class that should be used to store and
+ * recover database schema changes. The configuration properties for the
+ * history are prefixed with the 'database.history.' string.
+ */
+ private String databaseHistory = "class
io.debezium.relational.history.KafkaDatabaseHistory";
+ /**
+ * The path to the file that will be used to record the database history
+ */
+ private String databaseHistoryFileFilename;
+ /**
+ * A list of host/port pairs that the connector will use for establishing
+ * the initial connection to the Kafka cluster for retrieving database
+ * schema history previously stored by the connector. This should point to
+ * the same Kafka cluster used by the Kafka Connect process.
+ */
+ private String databaseHistoryKafkaBootstrapServers;
+ /**
+ * The number of attempts in a row that no data are returned from Kafka
+ * before recover completes. The maximum amount of time to wait after
+ * receiving no data is (recovery.attempts) x (recovery.poll.interval.ms).
+ */
+ private Integer databaseHistoryKafkaRecoveryAttempts = 100;
+ /**
+ * The number of milliseconds to wait while polling for persisted data
+ * during recovery. The option is a int type.
+ */
+ private Integer databaseHistoryKafkaRecoveryPollIntervalMs = 100;
+ /**
+ * The name of the topic for the database schema history
+ */
+ private String databaseHistoryKafkaTopic;
+ /**
+ * Resolvable hostname or IP address of the database server.
+ */
+ private String databaseHostname;
+ /**
+ * Password of the database user to be used when connecting to the
database.
+ */
+ private String databasePassword;
+ /**
+ * Port of the database server.
+ */
+ private Integer databasePort = 50000;
+ /**
+ * Unique name that identifies the database server and all recorded
offsets,
+ * and that is used as a prefix for all schemas and topics. Each distinct
+ * installation should have a separate namespace and be monitored by at
most
+ * one Debezium connector.
+ */
+ private String databaseServerName;
+ /**
+ * Name of the database user to be used when connecting to the database.
+ */
+ private String databaseUser;
+ /**
+ * Specify how DECIMAL and NUMERIC columns should be represented in change
+ * events, including:'precise' (the default) uses java.math.BigDecimal to
+ * represent values, which are encoded in the change events using a binary
+ * representation and Kafka Connect's
+ * 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to
+ * represent values; 'double' represents values using Java's 'double',
which
+ * may not offer the precision but will be far easier to use in consumers.
+ */
+ private String decimalHandlingMode = "precise";
+ /**
+ * Specify how failures during processing of events (i.e. when encountering
+ * a corrupted event) should be handled, including:'fail' (the default) an
+ * exception indicating the problematic event and its position is raised,
+ * causing the connector to be stopped; 'warn' the problematic event and
its
+ * position will be logged and the event will be skipped;'ignore' the
+ * problematic event will be skipped.
+ */
+ private String eventProcessingFailureHandlingMode = "fail";
+ /**
+ * Length of an interval in milli-seconds in in which the connector
+ * periodically sends heartbeat messages to a heartbeat topic. Use 0 to
+ * disable heartbeat messages. Disabled by default. The option is a int
+ * type.
+ */
+ private Integer heartbeatIntervalMs = 0;
+ /**
+ * The prefix that is used to name heartbeat topics.Defaults to
+ * __debezium-heartbeat.
+ */
+ private String heartbeatTopicsPrefix = "__debezium-heartbeat";
+ /**
+ * Maximum size of each batch of source records. Defaults to 2048.
+ */
+ private Integer maxBatchSize = 2048;
+ /**
+ * Maximum size of the queue for change events read from the database log
+ * but not yet recorded or forwarded. Defaults to 8192, and should always
be
+ * larger than the maximum batch size.
+ */
+ private Integer maxQueueSize = 8192;
+ /**
+ * Time to wait for new change events to appear after receiving no events,
+ * given in milliseconds. Defaults to 500 ms. The option is a long type.
+ */
+ private Long pollIntervalMs = 500L;
+ /**
+ * A delay period before a snapshot will begin, given in milliseconds.
+ * Defaults to 0 ms. The option is a long type.
+ */
+ private Long snapshotDelayMs = 0L;
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * performing a snapshot
+ */
+ private Integer snapshotFetchSize;
+ /**
+ * The criteria for running a snapshot upon startup of the connector.
+ * Options include: 'initial' (the default) to specify the connector should
+ * run a snapshot only when no offsets are available for the logical server
+ * name; 'schema_only' to specify the connector should run a snapshot of
the
+ * schema when no offsets are available for the logical server name.
+ */
+ private String snapshotMode = "initial";
+ /**
+ * This property contains a comma-separated list of fully-qualified tables
+ * (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
+ * thespecific connectors. Select statements for the individual tables are
+ * specified in further configuration properties, one for each table,
+ * identified by the id
+ * 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
+ * 'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME',
+ * respectively. The value of those properties is the select statement to
+ * use when retrieving data from the specific table during snapshotting. A
+ * possible use case for large append-only tables is setting a specific
+ * point where to start (resume) snapshotting, in case a previous
+ * snapshotting was interrupted.
+ */
+ private String snapshotSelectStatementOverrides;
+ /**
+ * A version of the format of the publicly visible source part in the
+ * message
+ */
+ private String sourceStructVersion = "v2";
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring
+ * (deprecated, use table.exclude.list instead)
+ */
+ private String tableBlacklist;
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring
+ */
+ private String tableExcludeList;
+ /**
+ * Flag specifying whether built-in tables should be ignored.
+ */
+ private Boolean tableIgnoreBuiltin = true;
+ /**
+ * The tables for which changes are to be captured
+ */
+ private String tableIncludeList;
+ /**
+ * The tables for which changes are to be captured (deprecated, use
+ * table.include.list instead)
+ */
+ private String tableWhitelist;
+ /**
+ * Time, date, and timestamps can be represented with different kinds of
+ * precisions, including:'adaptive' (the default) bases the precision of
+ * time, date, and timestamp values on the database column's precision;
+ * 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields
always
+ * use microseconds precision;'connect' always represents time, date, and
+ * timestamp values using Kafka Connect's built-in representations for
Time,
+ * Date, and Timestamp, which uses millisecond precision regardless of the
+ * database columns' precision .
+ */
+ private String timePrecisionMode = "adaptive";
+
+ public Map<String, Object> getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ public void setAdditionalProperties(Map<String, Object>
additionalProperties) {
+ this.additionalProperties = additionalProperties;
+ }
+
+ public Boolean getBridgeErrorHandler() {
+ return bridgeErrorHandler;
+ }
+
+ public void setBridgeErrorHandler(Boolean bridgeErrorHandler) {
+ this.bridgeErrorHandler = bridgeErrorHandler;
+ }
+
+ public Db2ConnectorEmbeddedDebeziumConfiguration getConfiguration() {
+ return configuration;
+ }
+
+ public void setConfiguration(
+ Db2ConnectorEmbeddedDebeziumConfiguration configuration) {
+ this.configuration = configuration;
+ }
+
+ public String getInternalKeyConverter() {
+ return internalKeyConverter;
+ }
+
+ public void setInternalKeyConverter(String internalKeyConverter) {
+ this.internalKeyConverter = internalKeyConverter;
+ }
+
+ public String getInternalValueConverter() {
+ return internalValueConverter;
+ }
+
+ public void setInternalValueConverter(String internalValueConverter) {
+ this.internalValueConverter = internalValueConverter;
+ }
+
+ public String getOffsetCommitPolicy() {
+ return offsetCommitPolicy;
+ }
+
+ public void setOffsetCommitPolicy(String offsetCommitPolicy) {
+ this.offsetCommitPolicy = offsetCommitPolicy;
+ }
+
+ public Long getOffsetCommitTimeoutMs() {
+ return offsetCommitTimeoutMs;
+ }
+
+ public void setOffsetCommitTimeoutMs(Long offsetCommitTimeoutMs) {
+ this.offsetCommitTimeoutMs = offsetCommitTimeoutMs;
+ }
+
+ public Long getOffsetFlushIntervalMs() {
+ return offsetFlushIntervalMs;
+ }
+
+ public void setOffsetFlushIntervalMs(Long offsetFlushIntervalMs) {
+ this.offsetFlushIntervalMs = offsetFlushIntervalMs;
+ }
+
+ public String getOffsetStorage() {
+ return offsetStorage;
+ }
+
+ public void setOffsetStorage(String offsetStorage) {
+ this.offsetStorage = offsetStorage;
+ }
+
+ public String getOffsetStorageFileName() {
+ return offsetStorageFileName;
+ }
+
+ public void setOffsetStorageFileName(String offsetStorageFileName) {
+ this.offsetStorageFileName = offsetStorageFileName;
+ }
+
+ public Integer getOffsetStoragePartitions() {
+ return offsetStoragePartitions;
+ }
+
+ public void setOffsetStoragePartitions(Integer offsetStoragePartitions) {
+ this.offsetStoragePartitions = offsetStoragePartitions;
+ }
+
+ public Integer getOffsetStorageReplicationFactor() {
+ return offsetStorageReplicationFactor;
+ }
+
+ public void setOffsetStorageReplicationFactor(
+ Integer offsetStorageReplicationFactor) {
+ this.offsetStorageReplicationFactor = offsetStorageReplicationFactor;
+ }
+
+ public String getOffsetStorageTopic() {
+ return offsetStorageTopic;
+ }
+
+ public void setOffsetStorageTopic(String offsetStorageTopic) {
+ this.offsetStorageTopic = offsetStorageTopic;
+ }
+
+ public Boolean getAutowiredEnabled() {
+ return autowiredEnabled;
+ }
+
+ public void setAutowiredEnabled(Boolean autowiredEnabled) {
+ this.autowiredEnabled = autowiredEnabled;
+ }
+
+ public String getColumnBlacklist() {
+ return columnBlacklist;
+ }
+
+ public void setColumnBlacklist(String columnBlacklist) {
+ this.columnBlacklist = columnBlacklist;
+ }
+
+ public String getColumnExcludeList() {
+ return columnExcludeList;
+ }
+
+ public void setColumnExcludeList(String columnExcludeList) {
+ this.columnExcludeList = columnExcludeList;
+ }
+
+ public String getDatabaseDbname() {
+ return databaseDbname;
+ }
+
+ public void setDatabaseDbname(String databaseDbname) {
+ this.databaseDbname = databaseDbname;
+ }
+
+ public String getDatabaseHistory() {
+ return databaseHistory;
+ }
+
+ public void setDatabaseHistory(String databaseHistory) {
+ this.databaseHistory = databaseHistory;
+ }
+
+ public String getDatabaseHistoryFileFilename() {
+ return databaseHistoryFileFilename;
+ }
+
+ public void setDatabaseHistoryFileFilename(
+ String databaseHistoryFileFilename) {
+ this.databaseHistoryFileFilename = databaseHistoryFileFilename;
+ }
+
+ public String getDatabaseHistoryKafkaBootstrapServers() {
+ return databaseHistoryKafkaBootstrapServers;
+ }
+
+ public void setDatabaseHistoryKafkaBootstrapServers(
+ String databaseHistoryKafkaBootstrapServers) {
+ this.databaseHistoryKafkaBootstrapServers =
databaseHistoryKafkaBootstrapServers;
+ }
+
+ public Integer getDatabaseHistoryKafkaRecoveryAttempts() {
+ return databaseHistoryKafkaRecoveryAttempts;
+ }
+
+ public void setDatabaseHistoryKafkaRecoveryAttempts(
+ Integer databaseHistoryKafkaRecoveryAttempts) {
+ this.databaseHistoryKafkaRecoveryAttempts =
databaseHistoryKafkaRecoveryAttempts;
+ }
+
+ public Integer getDatabaseHistoryKafkaRecoveryPollIntervalMs() {
+ return databaseHistoryKafkaRecoveryPollIntervalMs;
+ }
+
+ public void setDatabaseHistoryKafkaRecoveryPollIntervalMs(
+ Integer databaseHistoryKafkaRecoveryPollIntervalMs) {
+ this.databaseHistoryKafkaRecoveryPollIntervalMs =
databaseHistoryKafkaRecoveryPollIntervalMs;
+ }
+
+ public String getDatabaseHistoryKafkaTopic() {
+ return databaseHistoryKafkaTopic;
+ }
+
+ public void setDatabaseHistoryKafkaTopic(String databaseHistoryKafkaTopic)
{
+ this.databaseHistoryKafkaTopic = databaseHistoryKafkaTopic;
+ }
+
+ public String getDatabaseHostname() {
+ return databaseHostname;
+ }
+
+ public void setDatabaseHostname(String databaseHostname) {
+ this.databaseHostname = databaseHostname;
+ }
+
+ public String getDatabasePassword() {
+ return databasePassword;
+ }
+
+ public void setDatabasePassword(String databasePassword) {
+ this.databasePassword = databasePassword;
+ }
+
+ public Integer getDatabasePort() {
+ return databasePort;
+ }
+
+ public void setDatabasePort(Integer databasePort) {
+ this.databasePort = databasePort;
+ }
+
+ public String getDatabaseServerName() {
+ return databaseServerName;
+ }
+
+ public void setDatabaseServerName(String databaseServerName) {
+ this.databaseServerName = databaseServerName;
+ }
+
+ public String getDatabaseUser() {
+ return databaseUser;
+ }
+
+ public void setDatabaseUser(String databaseUser) {
+ this.databaseUser = databaseUser;
+ }
+
+ public String getDecimalHandlingMode() {
+ return decimalHandlingMode;
+ }
+
+ public void setDecimalHandlingMode(String decimalHandlingMode) {
+ this.decimalHandlingMode = decimalHandlingMode;
+ }
+
+ public String getEventProcessingFailureHandlingMode() {
+ return eventProcessingFailureHandlingMode;
+ }
+
+ public void setEventProcessingFailureHandlingMode(
+ String eventProcessingFailureHandlingMode) {
+ this.eventProcessingFailureHandlingMode =
eventProcessingFailureHandlingMode;
+ }
+
+ public Integer getHeartbeatIntervalMs() {
+ return heartbeatIntervalMs;
+ }
+
+ public void setHeartbeatIntervalMs(Integer heartbeatIntervalMs) {
+ this.heartbeatIntervalMs = heartbeatIntervalMs;
+ }
+
+ public String getHeartbeatTopicsPrefix() {
+ return heartbeatTopicsPrefix;
+ }
+
+ public void setHeartbeatTopicsPrefix(String heartbeatTopicsPrefix) {
+ this.heartbeatTopicsPrefix = heartbeatTopicsPrefix;
+ }
+
+ public Integer getMaxBatchSize() {
+ return maxBatchSize;
+ }
+
+ public void setMaxBatchSize(Integer maxBatchSize) {
+ this.maxBatchSize = maxBatchSize;
+ }
+
+ public Integer getMaxQueueSize() {
+ return maxQueueSize;
+ }
+
+ public void setMaxQueueSize(Integer maxQueueSize) {
+ this.maxQueueSize = maxQueueSize;
+ }
+
+ public Long getPollIntervalMs() {
+ return pollIntervalMs;
+ }
+
+ public void setPollIntervalMs(Long pollIntervalMs) {
+ this.pollIntervalMs = pollIntervalMs;
+ }
+
+ public Long getSnapshotDelayMs() {
+ return snapshotDelayMs;
+ }
+
+ public void setSnapshotDelayMs(Long snapshotDelayMs) {
+ this.snapshotDelayMs = snapshotDelayMs;
+ }
+
+ public Integer getSnapshotFetchSize() {
+ return snapshotFetchSize;
+ }
+
+ public void setSnapshotFetchSize(Integer snapshotFetchSize) {
+ this.snapshotFetchSize = snapshotFetchSize;
+ }
+
+ public String getSnapshotMode() {
+ return snapshotMode;
+ }
+
+ public void setSnapshotMode(String snapshotMode) {
+ this.snapshotMode = snapshotMode;
+ }
+
+ public String getSnapshotSelectStatementOverrides() {
+ return snapshotSelectStatementOverrides;
+ }
+
+ public void setSnapshotSelectStatementOverrides(
+ String snapshotSelectStatementOverrides) {
+ this.snapshotSelectStatementOverrides =
snapshotSelectStatementOverrides;
+ }
+
+ public String getSourceStructVersion() {
+ return sourceStructVersion;
+ }
+
+ public void setSourceStructVersion(String sourceStructVersion) {
+ this.sourceStructVersion = sourceStructVersion;
+ }
+
+ public String getTableBlacklist() {
+ return tableBlacklist;
+ }
+
+ public void setTableBlacklist(String tableBlacklist) {
+ this.tableBlacklist = tableBlacklist;
+ }
+
+ public String getTableExcludeList() {
+ return tableExcludeList;
+ }
+
+ public void setTableExcludeList(String tableExcludeList) {
+ this.tableExcludeList = tableExcludeList;
+ }
+
+ public Boolean getTableIgnoreBuiltin() {
+ return tableIgnoreBuiltin;
+ }
+
+ public void setTableIgnoreBuiltin(Boolean tableIgnoreBuiltin) {
+ this.tableIgnoreBuiltin = tableIgnoreBuiltin;
+ }
+
+ public String getTableIncludeList() {
+ return tableIncludeList;
+ }
+
+ public void setTableIncludeList(String tableIncludeList) {
+ this.tableIncludeList = tableIncludeList;
+ }
+
+ public String getTableWhitelist() {
+ return tableWhitelist;
+ }
+
+ public void setTableWhitelist(String tableWhitelist) {
+ this.tableWhitelist = tableWhitelist;
+ }
+
+ public String getTimePrecisionMode() {
+ return timePrecisionMode;
+ }
+
+ public void setTimePrecisionMode(String timePrecisionMode) {
+ this.timePrecisionMode = timePrecisionMode;
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConverter.java
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConverter.java
new file mode 100644
index 00000000000..8a8e087fdfe
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumDb2ComponentConverter.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.debezium.springboot;
+
+import java.util.LinkedHashSet;
+import java.util.Set;
+import javax.annotation.Generated;
+import org.springframework.beans.factory.annotation.Autowired;
+import
org.springframework.boot.context.properties.ConfigurationPropertiesBinding;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.convert.TypeDescriptor;
+import org.springframework.core.convert.converter.GenericConverter;
+import org.springframework.stereotype.Component;
+
+/**
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.springboot.maven.SpringBootAutoConfigurationMojo")
+@Configuration(proxyBeanMethods = false)
+@ConfigurationPropertiesBinding
+@Component
+public class DebeziumDb2ComponentConverter implements GenericConverter {
+
+ @Autowired
+ private ApplicationContext applicationContext;
+
+ public Set<ConvertiblePair> getConvertibleTypes() {
+ Set<ConvertiblePair> answer = new LinkedHashSet<>();
+ answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration.class));
+ return answer;
+ }
+
+ public Object convert(
+ Object source,
+ TypeDescriptor sourceType,
+ TypeDescriptor targetType) {
+ if (source == null) {
+ return null;
+ }
+ String ref = source.toString();
+ if (!ref.startsWith("#")) {
+ return null;
+ }
+ ref = ref.startsWith("#bean:") ? ref.substring(6) : ref.substring(1);
+ switch (targetType.getName()) {
+ case
"org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration":
return applicationContext.getBean(ref,
org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration.class);
+ }
+ return null;
+ }
+}
\ No newline at end of file
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/LICENSE.txt
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/LICENSE.txt
new file mode 100644
index 00000000000..6b0b1270ff0
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/LICENSE.txt
@@ -0,0 +1,203 @@
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/NOTICE.txt
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/NOTICE.txt
new file mode 100644
index 00000000000..2e215bf2e6b
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/NOTICE.txt
@@ -0,0 +1,11 @@
+ =========================================================================
+ == NOTICE file corresponding to the section 4 d of ==
+ == the Apache License, Version 2.0, ==
+ == in this case for the Apache Camel distribution. ==
+ =========================================================================
+
+ This product includes software developed by
+ The Apache Software Foundation (http://www.apache.org/).
+
+ Please read the different LICENSE files present in the licenses directory of
+ this distribution.
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.factories
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 00000000000..3d5b93ddef5
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,21 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentConverter,\
+org.apache.camel.component.debezium.springboot.DebeziumDb2ComponentAutoConfiguration
+
diff --git
a/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.provides
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.provides
new file mode 100644
index 00000000000..3aa97a514e1
--- /dev/null
+++
b/components-starter/camel-debezium-db2-starter/src/main/resources/META-INF/spring.provides
@@ -0,0 +1,17 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+provides: camel-debezium-db2
