[Github Actions] Periodic Sync Camel Spring Boot Master Branch

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

@@ -30,16 +30,16 @@ The component supports 44 options, which are listed below.
 | *camel.component.debezium-mongodb.collection-blacklist* | Description is not available here, please check Debezium website for corresponding key 'collection.blacklist' description. |  | String
 | *camel.component.debezium-mongodb.collection-whitelist* | The collections for which changes are to be captured |  | String
 | *camel.component.debezium-mongodb.configuration* | Allow pre-configured Configurations to be set. The option is a org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration type. |  | String
-| *camel.component.debezium-mongodb.connect-backoff-initial-delay-ms* | The initial delay when trying to reconnect to a primary after a connection cannot be made or when no primary is available. Defaults to 1 second (1000 ms). | 1000 | Long
-| *camel.component.debezium-mongodb.connect-backoff-max-delay-ms* | The maximum delay when trying to reconnect to a primary after a connection cannot be made or when no primary is available. Defaults to 120 second (120,000 ms). | 120000 | Long
+| *camel.component.debezium-mongodb.connect-backoff-initial-delay-ms* | The initial delay when trying to reconnect to a primary after a connection cannot be made or when no primary is available. Defaults to 1 second (1000 ms). The option is a long type. | 1s | String
+| *camel.component.debezium-mongodb.connect-backoff-max-delay-ms* | The maximum delay when trying to reconnect to a primary after a connection cannot be made or when no primary is available. Defaults to 120 second (120,000 ms). The option is a long type. | 120s | String
 | *camel.component.debezium-mongodb.connect-max-attempts* | Maximum number of failed connection attempts to a replica set primary before an exception occurs and task is aborted. Defaults to 16, which with the defaults for 'connect.backoff.initial.delay.ms' and 'connect.backoff.max.delay.ms' results in just over 20 minutes of attempts before failing. | 16 | Integer
 | *camel.component.debezium-mongodb.database-blacklist* | The databases for which changes are to be excluded |  | String
 | *camel.component.debezium-mongodb.database-history-file-filename* | The path to the file that will be used to record the database history |  | String
 | *camel.component.debezium-mongodb.database-whitelist* | The databases for which changes are to be captured |  | String
 | *camel.component.debezium-mongodb.enabled* | Whether to enable auto configuration of the debezium-mongodb component. This is enabled by default. |  | Boolean
 | *camel.component.debezium-mongodb.field-blacklist* | Description is not available here, please check Debezium website for corresponding key 'field.blacklist' description. |  | String
 | *camel.component.debezium-mongodb.field-renames* | Description is not available here, please check Debezium website for corresponding key 'field.renames' description. |  | String
-| *camel.component.debezium-mongodb.heartbeat-interval-ms* | 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. | 0 | Integer
+| *camel.component.debezium-mongodb.heartbeat-interval-ms* | 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. | 0s | String
 | *camel.component.debezium-mongodb.heartbeat-topics-prefix* | The prefix that is used to name heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat | String
 | *camel.component.debezium-mongodb.initial-sync-max-threads* | Maximum number of threads used to perform an initial sync of the collections in a replica set. Defaults to 1. | 1 | Integer
 | *camel.component.debezium-mongodb.internal-key-converter* | The Converter class that should be used to serialize and deserialize key data for offsets. The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter | String
@@ -61,9 +61,9 @@ The component supports 44 options, which are listed below.
 | *camel.component.debezium-mongodb.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-mongodb.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-mongodb.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-mongodb.poll-interval-ms* | Frequency in milliseconds to wait for new change events to appear after receiving no events. Defaults to 500ms. | 500 | Long
+| *camel.component.debezium-mongodb.poll-interval-ms* | Frequency in milliseconds to wait for new change events to appear after receiving no events. Defaults to 500ms. The option is a long type. | 0.5s | String
 | *camel.component.debezium-mongodb.skipped-operations* | The comma-separated list of operations to skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no operations will be skipped. |  | String
-| *camel.component.debezium-mongodb.snapshot-delay-ms* | The number of milliseconds to delay before a snapshot will begin. | 0 | Long
+| *camel.component.debezium-mongodb.snapshot-delay-ms* | The number of milliseconds to delay before a snapshot will begin. The option is a long type. | 0s | String
 | *camel.component.debezium-mongodb.snapshot-fetch-size* | The maximum number of records that should be loaded into memory while performing a snapshot |  | Integer
 | *camel.component.debezium-mongodb.snapshot-mode* | The criteria for running a snapshot upon startup of the connector. Options include: 'initial' (the default) to specify the connector should always perform an initial sync when required; 'never' to specify the connector should never perform an initial sync | initial | String
 | *camel.component.debezium-mongodb.source-struct-version* | A version of the format of the publicly visible source part in the message | v2 | String

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

@@ -132,15 +132,15 @@ public class DebeziumMongodbComponentConfiguration
     /**
      * The initial delay when trying to reconnect to a primary after a
      * connection cannot be made or when no primary is available. Defaults to 1
-     * second (1000 ms).
+     * second (1000 ms). The option is a long type.
      */
-    private Long connectBackoffInitialDelayMs = 1000L;
+    private String connectBackoffInitialDelayMs = "1s";
     /**
      * The maximum delay when trying to reconnect to a primary after a
      * connection cannot be made or when no primary is available. Defaults to
-     * 120 second (120,000 ms).
+     * 120 second (120,000 ms). The option is a long type.
      */
-    private Long connectBackoffMaxDelayMs = 120000L;
+    private String connectBackoffMaxDelayMs = "120s";
     /**
      * Maximum number of failed connection attempts to a replica set primary
      * before an exception occurs and task is aborted. Defaults to 16, which
@@ -174,9 +174,10 @@ public class DebeziumMongodbComponentConfiguration
     /**
      * 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.
+     * disable heartbeat messages. Disabled by default. The option is a int
+     * type.
      */
-    private Integer heartbeatIntervalMs = 0;
+    private String heartbeatIntervalMs = "0s";
     /**
      * The prefix that is used to name heartbeat topics.Defaults to
      * __debezium-heartbeat.
@@ -235,19 +236,20 @@ public class DebeziumMongodbComponentConfiguration
     private String mongodbUser;
     /**
      * Frequency in milliseconds to wait for new change events to appear after
-     * receiving no events. Defaults to 500ms.
+     * receiving no events. Defaults to 500ms. The option is a long type.
      */
-    private Long pollIntervalMs = 500L;
+    private String pollIntervalMs = "0.5s";
     /**
      * The comma-separated list of operations to skip during streaming, defined
      * as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no
      * operations will be skipped.
      */
     private String skippedOperations;
     /**
-     * The number of milliseconds to delay before a snapshot will begin.
+     * The number of milliseconds to delay before a snapshot will begin. The
+     * option is a long type.
      */
-    private Long snapshotDelayMs = 0L;
+    private String snapshotDelayMs = "0s";
     /**
      * The maximum number of records that should be loaded into memory while
      * performing a snapshot
@@ -403,20 +405,20 @@ public void setCollectionWhitelist(String collectionWhitelist) {
         this.collectionWhitelist = collectionWhitelist;
     }
 
-    public Long getConnectBackoffInitialDelayMs() {
+    public String getConnectBackoffInitialDelayMs() {
         return connectBackoffInitialDelayMs;
     }
 
     public void setConnectBackoffInitialDelayMs(
-            Long connectBackoffInitialDelayMs) {
+            String connectBackoffInitialDelayMs) {
         this.connectBackoffInitialDelayMs = connectBackoffInitialDelayMs;
     }
 
-    public Long getConnectBackoffMaxDelayMs() {
+    public String getConnectBackoffMaxDelayMs() {
         return connectBackoffMaxDelayMs;
     }
 
-    public void setConnectBackoffMaxDelayMs(Long connectBackoffMaxDelayMs) {
+    public void setConnectBackoffMaxDelayMs(String connectBackoffMaxDelayMs) {
         this.connectBackoffMaxDelayMs = connectBackoffMaxDelayMs;
     }
 
@@ -469,11 +471,11 @@ public void setFieldRenames(String fieldRenames) {
         this.fieldRenames = fieldRenames;
     }
 
-    public Integer getHeartbeatIntervalMs() {
+    public String getHeartbeatIntervalMs() {
         return heartbeatIntervalMs;
     }
 
-    public void setHeartbeatIntervalMs(Integer heartbeatIntervalMs) {
+    public void setHeartbeatIntervalMs(String heartbeatIntervalMs) {
         this.heartbeatIntervalMs = heartbeatIntervalMs;
     }
 
@@ -566,11 +568,11 @@ public void setMongodbUser(String mongodbUser) {
         this.mongodbUser = mongodbUser;
     }
 
-    public Long getPollIntervalMs() {
+    public String getPollIntervalMs() {
         return pollIntervalMs;
     }
 
-    public void setPollIntervalMs(Long pollIntervalMs) {
+    public void setPollIntervalMs(String pollIntervalMs) {
         this.pollIntervalMs = pollIntervalMs;
     }
 
@@ -582,11 +584,11 @@ public void setSkippedOperations(String skippedOperations) {
         this.skippedOperations = skippedOperations;
     }
 
-    public Long getSnapshotDelayMs() {
+    public String getSnapshotDelayMs() {
         return snapshotDelayMs;
     }
 
-    public void setSnapshotDelayMs(Long snapshotDelayMs) {
+    public void setSnapshotDelayMs(String snapshotDelayMs) {
         this.snapshotDelayMs = snapshotDelayMs;
     }