You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/03/29 05:10:45 UTC
[camel-kafka-connector] 02/02: Regen after upgrade
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-3.9.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit d8a923ed732913473d58013346aaafe62eeb23a6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Mar 29 07:10:25 2021 +0200
Regen after upgrade
---
.../connectors/camel-scheduler-source.json | 20 ++++-----
.../resources/camel-scheduler-source.json | 20 ++++-----
.../camel-scheduler-kafka-source-connector.adoc | 4 +-
.../CamelSchedulerSourceConnectorConfig.java | 16 +++----
docs/modules/ROOT/nav.adoc | 50 ++++++++++++++++++++++
docs/modules/ROOT/pages/connectors.adoc | 24 ++++++++++-
.../camel-scheduler-kafka-source-connector.adoc | 4 +-
7 files changed, 105 insertions(+), 33 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-scheduler-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-scheduler-source.json
index 05a9757..4da4b8b 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-scheduler-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-scheduler-source.json
@@ -77,6 +77,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.concurrentTasks": {
+ "name": "camel.source.endpoint.concurrentTasks",
+ "description": "Number of threads used by the scheduling thread pool. Is by default using a single thread",
+ "defaultValue": "1",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.delay": {
"name": "camel.source.endpoint.delay",
"description": "Milliseconds before the next poll.",
@@ -98,13 +105,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.poolSize": {
- "name": "camel.source.endpoint.poolSize",
- "description": "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread",
- "defaultValue": "1",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.repeatCount": {
"name": "camel.source.endpoint.repeatCount",
"description": "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
@@ -190,9 +190,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.scheduler.poolSize": {
- "name": "camel.component.scheduler.poolSize",
- "description": "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread",
+ "camel.component.scheduler.concurrentTasks": {
+ "name": "camel.component.scheduler.concurrentTasks",
+ "description": "Number of threads used by the scheduling thread pool. Is by default using a single thread",
"defaultValue": "1",
"priority": "MEDIUM",
"required": "false"
diff --git a/connectors/camel-scheduler-kafka-connector/src/generated/resources/camel-scheduler-source.json b/connectors/camel-scheduler-kafka-connector/src/generated/resources/camel-scheduler-source.json
index 05a9757..4da4b8b 100644
--- a/connectors/camel-scheduler-kafka-connector/src/generated/resources/camel-scheduler-source.json
+++ b/connectors/camel-scheduler-kafka-connector/src/generated/resources/camel-scheduler-source.json
@@ -77,6 +77,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.concurrentTasks": {
+ "name": "camel.source.endpoint.concurrentTasks",
+ "description": "Number of threads used by the scheduling thread pool. Is by default using a single thread",
+ "defaultValue": "1",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.delay": {
"name": "camel.source.endpoint.delay",
"description": "Milliseconds before the next poll.",
@@ -98,13 +105,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.poolSize": {
- "name": "camel.source.endpoint.poolSize",
- "description": "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread",
- "defaultValue": "1",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.repeatCount": {
"name": "camel.source.endpoint.repeatCount",
"description": "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
@@ -190,9 +190,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.scheduler.poolSize": {
- "name": "camel.component.scheduler.poolSize",
- "description": "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread",
+ "camel.component.scheduler.concurrentTasks": {
+ "name": "camel.component.scheduler.concurrentTasks",
+ "description": "Number of threads used by the scheduling thread pool. Is by default using a single thread",
"defaultValue": "1",
"priority": "MEDIUM",
"required": "false"
diff --git a/connectors/camel-scheduler-kafka-connector/src/main/docs/camel-scheduler-kafka-source-connector.adoc b/connectors/camel-scheduler-kafka-connector/src/main/docs/camel-scheduler-kafka-source-connector.adoc
index 5dd79c6..1e3ebc2 100644
--- a/connectors/camel-scheduler-kafka-connector/src/main/docs/camel-scheduler-kafka-source-connector.adoc
+++ b/connectors/camel-scheduler-kafka-connector/src/main/docs/camel-scheduler-kafka-source-connector.adoc
@@ -41,10 +41,10 @@ The camel-scheduler source connector supports 25 options, which are listed below
| *camel.source.endpoint.backoffErrorThreshold* | The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in. | null | false | MEDIUM
| *camel.source.endpoint.backoffIdleThreshold* | The number of subsequent idle polls that should happen before the backoffMultipler should kick-in. | null | false | MEDIUM
| *camel.source.endpoint.backoffMultiplier* | To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured. | null | false | MEDIUM
+| *camel.source.endpoint.concurrentTasks* | Number of threads used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
| *camel.source.endpoint.delay* | Milliseconds before the next poll. | 500L | false | MEDIUM
| *camel.source.endpoint.greedy* | If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages. | false | false | MEDIUM
| *camel.source.endpoint.initialDelay* | Milliseconds before the first poll starts. | 1000L | false | MEDIUM
-| *camel.source.endpoint.poolSize* | Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
| *camel.source.endpoint.repeatCount* | Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever. | 0L | false | MEDIUM
| *camel.source.endpoint.runLoggingLevel* | The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "TRACE" | false | MEDIUM
| *camel.source.endpoint.scheduledExecutorService* | Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool. | null | false | MEDIUM
@@ -55,7 +55,7 @@ The camel-scheduler source connector supports 25 options, which are listed below
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.component.scheduler.bridgeErrorHandler* | 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. | false | false | MEDIUM
| *camel.component.scheduler.autowiredEnabled* | 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. | true | false | MEDIUM
-| *camel.component.scheduler.poolSize* | Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
+| *camel.component.scheduler.concurrentTasks* | Number of threads used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
|===
diff --git a/connectors/camel-scheduler-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/scheduler/CamelSchedulerSourceConnectorConfig.java b/connectors/camel-scheduler-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/scheduler/CamelSchedulerSourceConnectorConfig.java
index f08d2e2..ae529e8 100644
--- a/connectors/camel-scheduler-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/scheduler/CamelSchedulerSourceConnectorConfig.java
+++ b/connectors/camel-scheduler-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/scheduler/CamelSchedulerSourceConnectorConfig.java
@@ -56,6 +56,9 @@ public class CamelSchedulerSourceConnectorConfig
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_CONF = "camel.source.endpoint.backoffMultiplier";
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_DOC = "To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured.";
public static final Integer CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_CONF = "camel.source.endpoint.concurrentTasks";
+ public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_DOC = "Number of threads used by the scheduling thread pool. Is by default using a single thread";
+ public static final Integer CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_DEFAULT = 1;
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_CONF = "camel.source.endpoint.delay";
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_DOC = "Milliseconds before the next poll.";
public static final Long CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_DEFAULT = 500L;
@@ -65,9 +68,6 @@ public class CamelSchedulerSourceConnectorConfig
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_CONF = "camel.source.endpoint.initialDelay";
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_DOC = "Milliseconds before the first poll starts.";
public static final Long CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_DEFAULT = 1000L;
- public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_CONF = "camel.source.endpoint.poolSize";
- public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_DOC = "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread";
- public static final Integer CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_DEFAULT = 1;
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_CONF = "camel.source.endpoint.repeatCount";
public static final String CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_DOC = "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.";
public static final Long CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_DEFAULT = 0L;
@@ -98,9 +98,9 @@ public class CamelSchedulerSourceConnectorConfig
public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_CONF = "camel.component.scheduler.autowiredEnabled";
public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_DOC = "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.";
public static final Boolean CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
- public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_CONF = "camel.component.scheduler.poolSize";
- public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_DOC = "Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread";
- public static final Integer CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_DEFAULT = 1;
+ public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_CONF = "camel.component.scheduler.concurrentTasks";
+ public static final String CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_DOC = "Number of threads used by the scheduling thread pool. Is by default using a single thread";
+ public static final Integer CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_DEFAULT = 1;
public CamelSchedulerSourceConnectorConfig(
ConfigDef config,
@@ -124,10 +124,10 @@ public class CamelSchedulerSourceConnectorConfig
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_ERROR_THRESHOLD_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_ERROR_THRESHOLD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_ERROR_THRESHOLD_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_IDLE_THRESHOLD_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_IDLE_THRESHOLD_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_IDLE_THRESHOLD_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_BACKOFF_MULTIPLIER_DOC);
+ conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_CONCURRENT_TASKS_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_DELAY_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_GREEDY_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SCHEDULER_ENDPOINT_GREEDY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_GREEDY_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_INITIAL_DELAY_DOC);
- conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_POOL_SIZE_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_REPEAT_COUNT_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_RUN_LOGGING_LEVEL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SCHEDULER_ENDPOINT_RUN_LOGGING_LEVEL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_RUN_LOGGING_LEVEL_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_SCHEDULED_EXECUTOR_SERVICE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SCHEDULER_ENDPOINT_SCHEDULED_EXECUTOR_SERVICE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_SCHEDULED_EXECUTOR_SERVICE_DOC);
@@ -138,7 +138,7 @@ public class CamelSchedulerSourceConnectorConfig
conf.define(CAMEL_SOURCE_SCHEDULER_ENDPOINT_USE_FIXED_DELAY_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SCHEDULER_ENDPOINT_USE_FIXED_DELAY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_ENDPOINT_USE_FIXED_DELAY_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_COMPONENT_BRIDGE_ERROR_HANDLER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SCHEDULER_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_COMPONENT_AUTOWIRED_ENABLED_DOC);
- conf.define(CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_COMPONENT_POOL_SIZE_DOC);
+ conf.define(CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SCHEDULER_COMPONENT_CONCURRENT_TASKS_DOC);
return conf;
}
}
\ No newline at end of file
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index a1a2468..cae1147 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -70,8 +70,52 @@
** camel-avro-kafka-connector
*** xref:connectors/camel-avro-kafka-source-connector.adoc[Source Docs]
*** xref:connectors/camel-avro-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-cw-kafka-connector
+*** xref:connectors/camel-aws-cw-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-ddb-kafka-connector
+*** xref:connectors/camel-aws-ddb-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-ddbstream-kafka-connector
+*** xref:connectors/camel-aws-ddbstream-kafka-source-connector.adoc[Source Docs]
+** camel-aws-ec2-kafka-connector
+*** xref:connectors/camel-aws-ec2-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-ecs-kafka-connector
+*** xref:connectors/camel-aws-ecs-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-eks-kafka-connector
+*** xref:connectors/camel-aws-eks-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-iam-kafka-connector
+*** xref:connectors/camel-aws-iam-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-kinesis-firehose-kafka-connector
+*** xref:connectors/camel-aws-kinesis-firehose-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-kinesis-kafka-connector
+*** xref:connectors/camel-aws-kinesis-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-aws-kinesis-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-kms-kafka-connector
+*** xref:connectors/camel-aws-kms-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-lambda-kafka-connector
+*** xref:connectors/camel-aws-lambda-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-mq-kafka-connector
+*** xref:connectors/camel-aws-mq-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-msk-kafka-connector
+*** xref:connectors/camel-aws-msk-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-s3-kafka-connector
+*** xref:connectors/camel-aws-s3-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-aws-s3-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-sdb-kafka-connector
+*** xref:connectors/camel-aws-sdb-kafka-sink-connector.adoc[Sink Docs]
** camel-aws-secrets-manager-kafka-connector
*** xref:connectors/camel-aws-secrets-manager-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-ses-kafka-connector
+*** xref:connectors/camel-aws-ses-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-sns-kafka-connector
+*** xref:connectors/camel-aws-sns-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-sqs-kafka-connector
+*** xref:connectors/camel-aws-sqs-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-aws-sqs-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-swf-kafka-connector
+*** xref:connectors/camel-aws-swf-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-aws-swf-kafka-sink-connector.adoc[Sink Docs]
+** camel-aws-translate-kafka-connector
+*** xref:connectors/camel-aws-translate-kafka-sink-connector.adoc[Sink Docs]
** camel-aws2-athena-kafka-connector
*** xref:connectors/camel-aws2-athena-kafka-sink-connector.adoc[Sink Docs]
** camel-aws2-cw-kafka-connector
@@ -117,9 +161,15 @@
*** xref:connectors/camel-aws2-sts-kafka-sink-connector.adoc[Sink Docs]
** camel-aws2-translate-kafka-connector
*** xref:connectors/camel-aws2-translate-kafka-sink-connector.adoc[Sink Docs]
+** camel-azure-blob-kafka-connector
+*** xref:connectors/camel-azure-blob-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-azure-blob-kafka-sink-connector.adoc[Sink Docs]
** camel-azure-eventhubs-kafka-connector
*** xref:connectors/camel-azure-eventhubs-kafka-source-connector.adoc[Source Docs]
*** xref:connectors/camel-azure-eventhubs-kafka-sink-connector.adoc[Sink Docs]
+** camel-azure-queue-kafka-connector
+*** xref:connectors/camel-azure-queue-kafka-source-connector.adoc[Source Docs]
+*** xref:connectors/camel-azure-queue-kafka-sink-connector.adoc[Sink Docs]
** camel-azure-storage-blob-kafka-connector
*** xref:connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs]
*** xref:connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs]
diff --git a/docs/modules/ROOT/pages/connectors.adoc b/docs/modules/ROOT/pages/connectors.adoc
index efd24f8..e49a3a5 100644
--- a/docs/modules/ROOT/pages/connectors.adoc
+++ b/docs/modules/ROOT/pages/connectors.adoc
@@ -2,7 +2,7 @@
= Supported connectors and documentation
// kafka-connectors list: START
-Number of Camel Kafka connectors: 337
+Number of Camel Kafka connectors: 359
[width="100%",cols="4,1,1,1,1,1",options="header"]
|===
@@ -27,7 +27,27 @@ Number of Camel Kafka connectors: 337
| *camel-atomix-set-kafka-connector* | true | true | xref:connectors/camel-atomix-set-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-atomix-set-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-atomix-set-kafka-connector/0.7.2/camel-atomix-set-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-atomix-value-kafka-connector* | true | true | xref:connectors/camel-atomix-value-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-atomix-value-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-atomix-value-kafka-connector/0.7.2/camel-atomix-value-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-avro-kafka-connector* | true | true | xref:connectors/camel-avro-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-avro-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-avro-kafka-connector/0.7.2/camel-avro-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-cw-kafka-connector* | true | false | xref:connectors/camel-aws-cw-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-cw-kafka-connector/0.7.2/camel-aws-cw-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-ddb-kafka-connector* | true | false | xref:connectors/camel-aws-ddb-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-ddb-kafka-connector/0.7.2/camel-aws-ddb-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-ddbstream-kafka-connector* | false | true | | xref:connectors/camel-aws-ddbstream-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-ddbstream-kafka-connector/0.7.2/camel-aws-ddbstream-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-ec2-kafka-connector* | true | false | xref:connectors/camel-aws-ec2-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-ec2-kafka-connector/0.7.2/camel-aws-ec2-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-ecs-kafka-connector* | true | false | xref:connectors/camel-aws-ecs-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-ecs-kafka-connector/0.7.2/camel-aws-ecs-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-eks-kafka-connector* | true | false | xref:connectors/camel-aws-eks-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-eks-kafka-connector/0.7.2/camel-aws-eks-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-iam-kafka-connector* | true | false | xref:connectors/camel-aws-iam-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-iam-kafka-connector/0.7.2/camel-aws-iam-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-kinesis-firehose-kafka-connector* | true | false | xref:connectors/camel-aws-kinesis-firehose-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-kinesis-firehose-kafka-connector/0.7.2/camel-aws-kinesis-firehose-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-kinesis-kafka-connector* | true | true | xref:connectors/camel-aws-kinesis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-kinesis-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-kinesis-kafka-connector/0.7.2/camel-aws-kinesis-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-kms-kafka-connector* | true | false | xref:connectors/camel-aws-kms-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-kms-kafka-connector/0.7.2/camel-aws-kms-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-lambda-kafka-connector* | true | false | xref:connectors/camel-aws-lambda-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-lambda-kafka-connector/0.7.2/camel-aws-lambda-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-mq-kafka-connector* | true | false | xref:connectors/camel-aws-mq-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-mq-kafka-connector/0.7.2/camel-aws-mq-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-msk-kafka-connector* | true | false | xref:connectors/camel-aws-msk-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-msk-kafka-connector/0.7.2/camel-aws-msk-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-s3-kafka-connector* | true | true | xref:connectors/camel-aws-s3-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-s3-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-s3-kafka-connector/0.7.2/camel-aws-s3-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-sdb-kafka-connector* | true | false | xref:connectors/camel-aws-sdb-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-sdb-kafka-connector/0.7.2/camel-aws-sdb-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws-secrets-manager-kafka-connector* | true | false | xref:connectors/camel-aws-secrets-manager-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-secrets-manager-kafka-connector/0.7.2/camel-aws-secrets-manager-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-ses-kafka-connector* | true | false | xref:connectors/camel-aws-ses-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-ses-kafka-connector/0.7.2/camel-aws-ses-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-sns-kafka-connector* | true | false | xref:connectors/camel-aws-sns-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-sns-kafka-connector/0.7.2/camel-aws-sns-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-sqs-kafka-connector* | true | true | xref:connectors/camel-aws-sqs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-sqs-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-sqs-kafka-connector/0.7.2/camel-aws-sqs-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-swf-kafka-connector* | true | true | xref:connectors/camel-aws-swf-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-swf-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-swf-kafka-connector/0.7.2/camel-aws-swf-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-aws-translate-kafka-connector* | true | false | xref:connectors/camel-aws-translate-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws-translate-kafka-connector/0.7.2/camel-aws-translate-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws2-athena-kafka-connector* | true | false | xref:connectors/camel-aws2-athena-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-athena-kafka-connector/0.7.2/camel-aws2-athena-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws2-cw-kafka-connector* | true | false | xref:connectors/camel-aws2-cw-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-cw-kafka-connector/0.7.2/camel-aws2-cw-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws2-ddb-kafka-connector* | true | false | xref:connectors/camel-aws2-ddb-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-ddb-kafka-connector/0.7.2/camel-aws2-ddb-kafka-connector-0.7.2-package.tar.gz[Download]
@@ -49,7 +69,9 @@ Number of Camel Kafka connectors: 337
| *camel-aws2-sqs-kafka-connector* | true | true | xref:connectors/camel-aws2-sqs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws2-sqs-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sqs-kafka-connector/0.7.2/camel-aws2-sqs-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws2-sts-kafka-connector* | true | false | xref:connectors/camel-aws2-sts-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sts-kafka-connector/0.7.2/camel-aws2-sts-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-aws2-translate-kafka-connector* | true | false | xref:connectors/camel-aws2-translate-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-translate-kafka-connector/0.7.2/camel-aws2-translate-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-azure-blob-kafka-connector* | true | true | xref:connectors/camel-azure-blob-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-blob-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-blob-kafka-connector/0.7.2/camel-azure-blob-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-azure-eventhubs-kafka-connector* | true | true | xref:connectors/camel-azure-eventhubs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-eventhubs-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-eventhubs-kafka-connector/0.7.2/camel-azure-eventhubs-kafka-connector-0.7.2-package.tar.gz[Download]
+| *camel-azure-queue-kafka-connector* | true | true | xref:connectors/camel-azure-queue-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-queue-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-queue-kafka-connector/0.7.2/camel-azure-queue-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-azure-storage-blob-kafka-connector* | true | true | xref:connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-storage-blob-kafka-connector/0.7.2/camel-azure-storage-blob-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-azure-storage-datalake-kafka-connector* | true | true | xref:connectors/camel-azure-storage-datalake-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-storage-datalake-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-storage-datalake-kafka-connector/0.7.2/camel-azure-storage-datalake-kafka-connector-0.7.2-package.tar.gz[Download]
| *camel-azure-storage-queue-kafka-connector* | true | true | xref:connectors/camel-azure-storage-queue-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-azure-storage-queue-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-azure-storage-queue-kafka-connector/0.7.2/camel-azure-storage-queue-kafka-connector-0.7.2-package.tar.gz[Download]
diff --git a/docs/modules/ROOT/pages/connectors/camel-scheduler-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-scheduler-kafka-source-connector.adoc
index 5dd79c6..1e3ebc2 100644
--- a/docs/modules/ROOT/pages/connectors/camel-scheduler-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-scheduler-kafka-source-connector.adoc
@@ -41,10 +41,10 @@ The camel-scheduler source connector supports 25 options, which are listed below
| *camel.source.endpoint.backoffErrorThreshold* | The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in. | null | false | MEDIUM
| *camel.source.endpoint.backoffIdleThreshold* | The number of subsequent idle polls that should happen before the backoffMultipler should kick-in. | null | false | MEDIUM
| *camel.source.endpoint.backoffMultiplier* | To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured. | null | false | MEDIUM
+| *camel.source.endpoint.concurrentTasks* | Number of threads used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
| *camel.source.endpoint.delay* | Milliseconds before the next poll. | 500L | false | MEDIUM
| *camel.source.endpoint.greedy* | If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages. | false | false | MEDIUM
| *camel.source.endpoint.initialDelay* | Milliseconds before the first poll starts. | 1000L | false | MEDIUM
-| *camel.source.endpoint.poolSize* | Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
| *camel.source.endpoint.repeatCount* | Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever. | 0L | false | MEDIUM
| *camel.source.endpoint.runLoggingLevel* | The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "TRACE" | false | MEDIUM
| *camel.source.endpoint.scheduledExecutorService* | Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool. | null | false | MEDIUM
@@ -55,7 +55,7 @@ The camel-scheduler source connector supports 25 options, which are listed below
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.component.scheduler.bridgeErrorHandler* | 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. | false | false | MEDIUM
| *camel.component.scheduler.autowiredEnabled* | 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. | true | false | MEDIUM
-| *camel.component.scheduler.poolSize* | Number of core threads in the thread pool used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
+| *camel.component.scheduler.concurrentTasks* | Number of threads used by the scheduling thread pool. Is by default using a single thread | 1 | false | MEDIUM
|===