This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 31a742c6ff993946beb7e903115464cd00ea2764
Author: Andrea Cosentino <anco...@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
|===
