This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 80716bf Regen
80716bf is described below
commit 80716bffba27ada39f0853c8767a4dbb6274988a
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Oct 31 05:35:31 2019 +0100
Regen
---
.../src/main/docs/debezium-postgres-component.adoc | 4 +-
.../DebeziumPostgresEndpointBuilderFactory.java | 133 +++++++++++++++++++++
docs/components/modules/ROOT/nav.adoc | 1 +
.../ROOT/pages}/debezium-postgres-component.adoc | 5 +-
docs/components/modules/ROOT/pages/index.adoc | 4 +-
.../DebeziumPostgresComponentConfiguration.java | 4 +-
.../camel-spring-boot-dependencies/pom.xml | 6 +-
7 files changed, 147 insertions(+), 10 deletions(-)
diff --git
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
b/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
index 0dbbf9f..53648a1 100644
---
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
+++
b/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
@@ -186,12 +186,12 @@ The component supports 57 options, which are listed below.
| *camel.component.debezium-postgres.configuration.max-batch-size* | Any
optional parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | 2048 | Integer
| *camel.component.debezium-postgres.configuration.max-queue-size* | Any
optional parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | 8192 | Integer
| *camel.component.debezium-postgres.configuration.name* | Unique name for the
connector. Attempting to register again with the same name will fail. | |
String
-| *camel.component.debezium-postgres.configuration.offset-commit-policy* | 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. |
io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy | String
+| *camel.component.debezium-postgres.configuration.offset-commit-policy* | 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. |
io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy | String
| *camel.component.debezium-postgres.configuration.offset-commit-timeout-ms* |
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. | 5000 | Long
| *camel.component.debezium-postgres.configuration.offset-flush-interval-ms* |
Interval at which to try committing offsets. The default is 1 minute. | 60000 |
Long
| *camel.component.debezium-postgres.configuration.offset-storage* | The name
of the Java class that is responsible for persistence of connector offsets. |
org.apache.kafka.connect.storage.FileOffsetBackingStore | String
| *camel.component.debezium-postgres.configuration.offset-storage-file-name* |
Path to file where offsets are to be stored. Required when offset.storage is
set to the FileOffsetBackingStore | | String
-| *camel.component.debezium-postgres.configuration.offset-storage-partitions*
| The number of partitions used when creating the offset storage topic.
Required when offset.storage is set to the <������>.KafkaOffsetBackingStore. |
| Integer
+| *camel.component.debezium-postgres.configuration.offset-storage-partitions*
| The number of partitions used when creating the offset storage topic.
Required when offset.storage is set to the <…>.KafkaOffsetBackingStore. | |
Integer
|
*camel.component.debezium-postgres.configuration.offset-storage-replication-factor*
| Replication factor used when creating the offset storage topic. Required
when offset.storage is set to the KafkaOffsetBackingStore | | Integer
| *camel.component.debezium-postgres.configuration.offset-storage-topic* | The
name of the Kafka topic where offsets are to be stored. Required when
offset.storage is set to the KafkaOffsetBackingStore. | | String
| *camel.component.debezium-postgres.configuration.plugin-name* | Any optional
parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | decoderbufs | String
diff --git
a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
new file mode 100644
index 0000000..6606d50
--- /dev/null
+++
b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -0,0 +1,133 @@
+/*
+ * 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.builder.endpoint.dsl;
+
+import javax.annotation.Generated;
+import org.apache.camel.builder.EndpointConsumerBuilder;
+import org.apache.camel.builder.EndpointProducerBuilder;
+import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
+
+/**
+ * Represents a Debezium PostgresSQL endpoint which is used to capture changes
+ * in PostgresSQL database so that that applications can see those changes and
+ * respond to them.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
+public interface DebeziumPostgresEndpointBuilderFactory {
+
+
+ /**
+ * Builder for endpoint for the Debezium PostgresSQL Connector component.
+ */
+ public interface DebeziumPostgresEndpointBuilder
+ extends
+ EndpointConsumerBuilder {
+ default AdvancedDebeziumPostgresEndpointBuilder advanced() {
+ return (AdvancedDebeziumPostgresEndpointBuilder) this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint for the Debezium PostgresSQL Connector
+ * component.
+ */
+ public interface AdvancedDebeziumPostgresEndpointBuilder
+ extends
+ EndpointConsumerBuilder {
+ default DebeziumPostgresEndpointBuilder basic() {
+ return (DebeziumPostgresEndpointBuilder) this;
+ }
+ /**
+ * Whether the endpoint should use basic property binding (Camel 2.x)
or
+ * the newer property binding with additional capabilities.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Group: advanced
+ */
+ default AdvancedDebeziumPostgresEndpointBuilder basicPropertyBinding(
+ boolean basicPropertyBinding) {
+ doSetProperty("basicPropertyBinding", basicPropertyBinding);
+ return this;
+ }
+ /**
+ * Whether the endpoint should use basic property binding (Camel 2.x)
or
+ * the newer property binding with additional capabilities.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Group: advanced
+ */
+ default AdvancedDebeziumPostgresEndpointBuilder basicPropertyBinding(
+ String basicPropertyBinding) {
+ doSetProperty("basicPropertyBinding", basicPropertyBinding);
+ return this;
+ }
+ /**
+ * Sets whether synchronous processing should be strictly used, or
Camel
+ * is allowed to use asynchronous processing (if supported).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Group: advanced
+ */
+ default AdvancedDebeziumPostgresEndpointBuilder synchronous(
+ boolean synchronous) {
+ doSetProperty("synchronous", synchronous);
+ return this;
+ }
+ /**
+ * Sets whether synchronous processing should be strictly used, or
Camel
+ * is allowed to use asynchronous processing (if supported).
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Group: advanced
+ */
+ default AdvancedDebeziumPostgresEndpointBuilder synchronous(
+ String synchronous) {
+ doSetProperty("synchronous", synchronous);
+ return this;
+ }
+ }
+ /**
+ * Debezium PostgresSQL Connector (camel-debezium-postgres)
+ * Represents a Debezium PostgresSQL endpoint which is used to capture
+ * changes in PostgresSQL database so that that applications can see those
+ * changes and respond to them.
+ *
+ * Category: database,sql,postgres
+ * Available as of version: 3.0
+ * Maven coordinates: org.apache.camel:camel-debezium-postgres
+ *
+ * Syntax: <code>debezium-postgres:name</code>
+ *
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the
same
+ * name will fail.
+ */
+ default DebeziumPostgresEndpointBuilder debeziumPostgres(String path) {
+ class DebeziumPostgresEndpointBuilderImpl extends
AbstractEndpointBuilder implements DebeziumPostgresEndpointBuilder,
AdvancedDebeziumPostgresEndpointBuilder {
+ public DebeziumPostgresEndpointBuilderImpl(String path) {
+ super("debezium-postgres", path);
+ }
+ }
+ return new DebeziumPostgresEndpointBuilderImpl(path);
+ }
+}
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc
b/docs/components/modules/ROOT/nav.adoc
index 8649536..2aa3c9f 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -88,6 +88,7 @@
* xref:dataset-component.adoc[Dataset Component]
* xref:dataset-test-component.adoc[DataSet Test Component]
* xref:debezium-mysql-component.adoc[Debezium MySQL Connector Component]
+* xref:debezium-postgres-component.adoc[Debezium PostgresSQL Connector
Component]
* xref:digitalocean-component.adoc[DigitalOcean Component]
* xref:direct-component.adoc[Direct Component]
* xref:direct-vm-component.adoc[Direct VM Component]
diff --git
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
similarity index 99%
copy from
components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
copy to docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
index 0dbbf9f..d8f5b91 100644
---
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
@@ -1,5 +1,6 @@
[[debezium-postgres-component]]
= Debezium PostgresSQL Connector Component
+:page-source:
components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
*Since Camel 3.0*
@@ -186,12 +187,12 @@ The component supports 57 options, which are listed below.
| *camel.component.debezium-postgres.configuration.max-batch-size* | Any
optional parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | 2048 | Integer
| *camel.component.debezium-postgres.configuration.max-queue-size* | Any
optional parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | 8192 | Integer
| *camel.component.debezium-postgres.configuration.name* | Unique name for the
connector. Attempting to register again with the same name will fail. | |
String
-| *camel.component.debezium-postgres.configuration.offset-commit-policy* | 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. |
io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy | String
+| *camel.component.debezium-postgres.configuration.offset-commit-policy* | 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. |
io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy | String
| *camel.component.debezium-postgres.configuration.offset-commit-timeout-ms* |
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. | 5000 | Long
| *camel.component.debezium-postgres.configuration.offset-flush-interval-ms* |
Interval at which to try committing offsets. The default is 1 minute. | 60000 |
Long
| *camel.component.debezium-postgres.configuration.offset-storage* | The name
of the Java class that is responsible for persistence of connector offsets. |
org.apache.kafka.connect.storage.FileOffsetBackingStore | String
| *camel.component.debezium-postgres.configuration.offset-storage-file-name* |
Path to file where offsets are to be stored. Required when offset.storage is
set to the FileOffsetBackingStore | | String
-| *camel.component.debezium-postgres.configuration.offset-storage-partitions*
| The number of partitions used when creating the offset storage topic.
Required when offset.storage is set to the <������>.KafkaOffsetBackingStore. |
| Integer
+| *camel.component.debezium-postgres.configuration.offset-storage-partitions*
| The number of partitions used when creating the offset storage topic.
Required when offset.storage is set to the <…>.KafkaOffsetBackingStore. | |
Integer
|
*camel.component.debezium-postgres.configuration.offset-storage-replication-factor*
| Replication factor used when creating the offset storage topic. Required
when offset.storage is set to the KafkaOffsetBackingStore | | Integer
| *camel.component.debezium-postgres.configuration.offset-storage-topic* | The
name of the Kafka topic where offsets are to be stored. Required when
offset.storage is set to the KafkaOffsetBackingStore. | | String
| *camel.component.debezium-postgres.configuration.plugin-name* | Any optional
parameters used by logical decoding plugin. Semi-colon separated. E.g.
'add-tables=public.table,public.table2;include-lsn=true' | decoderbufs | String
diff --git a/docs/components/modules/ROOT/pages/index.adoc
b/docs/components/modules/ROOT/pages/index.adoc
index 930de68..16f40ca 100644
--- a/docs/components/modules/ROOT/pages/index.adoc
+++ b/docs/components/modules/ROOT/pages/index.adoc
@@ -6,7 +6,7 @@ The following Apache Camel artifacts are provided:
== Components
// components: START
-Number of Components: 299 in 237 JAR artifacts (0 deprecated)
+Number of Components: 300 in 238 JAR artifacts (0 deprecated)
[width="100%",cols="4,1,5",options="header"]
|===
@@ -150,6 +150,8 @@ Number of Components: 299 in 237 JAR artifacts (0
deprecated)
| xref:debezium-mysql-component.adoc[Debezium MySQL Connector]
(camel-debezium-mysql) | 3.0 | Represents a Debezium MySQL endpoint which is
used to capture changes in MySQL database so that that applications can see
those changes and respond to them.
+| xref:debezium-postgres-component.adoc[Debezium PostgresSQL Connector]
(camel-debezium-postgres) | 3.0 | Represents a Debezium PostgresSQL endpoint
which is used to capture changes in PostgresSQL database so that that
applications can see those changes and respond to them.
+
| xref:digitalocean-component.adoc[DigitalOcean] (camel-digitalocean) | 2.19 |
The DigitalOcean component allows you to manage Droplets and resources within
the DigitalOcean cloud.
| xref:direct-component.adoc[Direct] (camel-direct) | 1.0 | The direct
component provides direct, synchronous call to another endpoint from the same
CamelContext.
diff --git
a/platforms/spring-boot/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
b/platforms/spring-boot/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
index 8cda09c..b82f9e2 100644
---
a/platforms/spring-boot/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
+++
b/platforms/spring-boot/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
@@ -358,7 +358,7 @@ public class DebeziumPostgresComponentConfiguration
* 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
+ * implement the interface <…>.OffsetCommitPolicy. The default is a
* periodic commit policy based upon time intervals.
*/
private String offsetCommitPolicy =
"io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy";
@@ -376,7 +376,7 @@ public class DebeziumPostgresComponentConfiguration
/**
* The number of partitions used when creating the offset storage
topic.
* Required when offset.storage is set to the
- * <������>.KafkaOffsetBackingStore.
+ * <…>.KafkaOffsetBackingStore.
*/
private Integer offsetStoragePartitions;
/**
diff --git
a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
index ca0de40..82a9162 100644
---
a/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
+++
b/platforms/spring-boot/spring-boot-dm/camel-spring-boot-dependencies/pom.xml
@@ -1069,17 +1069,17 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-debezium-postgres</artifactId>
+ <artifactId>camel-debezium-parent</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-debezium-postgres-starter</artifactId>
+ <artifactId>camel-debezium-postgres</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-debezium-parent</artifactId>
+ <artifactId>camel-debezium-postgres-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
