You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by va...@apache.org on 2021/03/11 09:05:55 UTC
[camel-kafka-connector] 09/09: chore: regen
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit a85a209e9b80e8646f702cd08d400a4b6a633f25
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Wed Mar 10 17:30:52 2021 +0100
chore: regen
---
.../resources/connectors/camel-aws2-s3-sink.json | 4 +-
.../resources/connectors/camel-aws2-s3-source.json | 4 +-
.../resources/connectors/camel-aws2-sns-sink.json | 4 +-
.../resources/connectors/camel-aws2-sqs-sink.json | 4 +-
.../connectors/camel-aws2-sqs-source.json | 4 +-
.../connectors/camel-netty-http-sink.json | 14 ++++++
.../connectors/camel-netty-http-source.json | 14 ++++++
.../resources/connectors/camel-netty-sink.json | 14 ++++++
.../resources/connectors/camel-netty-source.json | 14 ++++++
.../connectors/camel-spring-rabbitmq-source.json | 47 ++++++++++++++++++++
.../generated/resources/camel-aws2-s3-sink.json | 4 +-
.../generated/resources/camel-aws2-s3-source.json | 4 +-
.../docs/camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../aws2s3/CamelAws2s3SinkConnectorConfig.java | 4 +-
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 4 +-
.../generated/resources/camel-aws2-sns-sink.json | 4 +-
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 4 +-
.../generated/resources/camel-aws2-sqs-sink.json | 4 +-
.../generated/resources/camel-aws2-sqs-source.json | 4 +-
.../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 +-
.../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 4 +-
.../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 4 +-
.../generated/resources/camel-netty-http-sink.json | 14 ++++++
.../resources/camel-netty-http-source.json | 14 ++++++
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../CamelNettyhttpSinkConnectorConfig.java | 8 ++++
.../CamelNettyhttpSourceConnectorConfig.java | 8 ++++
.../src/generated/resources/camel-netty-sink.json | 14 ++++++
.../generated/resources/camel-netty-source.json | 14 ++++++
.../docs/camel-netty-kafka-sink-connector.adoc | 4 +-
.../docs/camel-netty-kafka-source-connector.adoc | 4 +-
.../netty/CamelNettySinkConnectorConfig.java | 8 ++++
.../netty/CamelNettySourceConnectorConfig.java | 8 ++++
.../resources/camel-spring-rabbitmq-source.json | 47 ++++++++++++++++++++
...mel-spring-rabbitmq-kafka-source-connector.adoc | 8 +++-
.../CamelSpringrabbitmqSourceConnectorConfig.java | 24 +++++++++++
docs/modules/ROOT/nav.adoc | 50 ++++++++++++++++++++++
docs/modules/ROOT/pages/connectors.adoc | 24 ++++++++++-
.../camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 +-
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../camel-netty-kafka-sink-connector.adoc | 4 +-
.../camel-netty-kafka-source-connector.adoc | 4 +-
...mel-spring-rabbitmq-kafka-source-connector.adoc | 8 +++-
52 files changed, 423 insertions(+), 61 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
index 9e183fa..e5674e6 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
@@ -30,7 +30,7 @@
"camel.sink.endpoint.autoCreateBucket": {
"name": "camel.sink.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -223,7 +223,7 @@
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
index 8621e81..d1169e8 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
@@ -30,7 +30,7 @@
"camel.source.endpoint.autoCreateBucket": {
"name": "camel.source.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -386,7 +386,7 @@
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
index 7b059d4..0ef5538 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sns-sink.json
@@ -24,7 +24,7 @@
"camel.sink.endpoint.autoCreateTopic": {
"name": "camel.sink.endpoint.autoCreateTopic",
"description": "Setting the autocreation of the topic",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -184,7 +184,7 @@
"camel.component.aws2-sns.autoCreateTopic": {
"name": "camel.component.aws2-sns.autoCreateTopic",
"description": "Setting the autocreation of the topic",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
index 33feaa7..8272ee5 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
@@ -31,7 +31,7 @@
"camel.sink.endpoint.autoCreateQueue": {
"name": "camel.sink.endpoint.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -235,7 +235,7 @@
"camel.component.aws2-sqs.autoCreateQueue": {
"name": "camel.component.aws2-sqs.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
index 22ad918..0a191ab 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
@@ -31,7 +31,7 @@
"camel.source.endpoint.autoCreateQueue": {
"name": "camel.source.endpoint.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -411,7 +411,7 @@
"camel.component.aws2-sqs.autoCreateQueue": {
"name": "camel.component.aws2-sqs.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
index f65220a..fcf5581 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-sink.json
@@ -180,6 +180,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hostnameVerification": {
+ "name": "camel.sink.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.allowSerializedHeaders": {
"name": "camel.sink.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -506,6 +513,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.hostnameVerification": {
+ "name": "camel.component.netty-http.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.allowSerializedHeaders": {
"name": "camel.component.netty-http.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
index a0e8a6e..6ac3af1 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-http-source.json
@@ -282,6 +282,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hostnameVerification": {
+ "name": "camel.source.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.allowSerializedHeaders": {
"name": "camel.source.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -683,6 +690,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.hostnameVerification": {
+ "name": "camel.component.netty-http.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.allowSerializedHeaders": {
"name": "camel.component.netty-http.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
index 04d72ab..7bcdce9 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
@@ -160,6 +160,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hostnameVerification": {
+ "name": "camel.sink.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.allowSerializedHeaders": {
"name": "camel.sink.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -506,6 +513,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.hostnameVerification": {
+ "name": "camel.component.netty.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.allowSerializedHeaders": {
"name": "camel.component.netty.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
index 6a7e1ba..171e4aa 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
@@ -221,6 +221,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hostnameVerification": {
+ "name": "camel.source.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.allowSerializedHeaders": {
"name": "camel.source.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -630,6 +637,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.hostnameVerification": {
+ "name": "camel.component.netty.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.allowSerializedHeaders": {
"name": "camel.component.netty.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
index adbe1f5..309945c 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
@@ -144,6 +144,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.concurrentConsumers": {
+ "name": "camel.source.endpoint.concurrentConsumers",
+ "description": "The number of consumers",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.exceptionHandler": {
"name": "camel.source.endpoint.exceptionHandler",
"description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -161,6 +167,23 @@
"InOptionalOut"
]
},
+ "camel.source.endpoint.maxConcurrentConsumers": {
+ "name": "camel.source.endpoint.maxConcurrentConsumers",
+ "description": "The maximum number of consumers (available only with SMLC)",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.messageListenerContainerType": {
+ "name": "camel.source.endpoint.messageListenerContainerType",
+ "description": "The type of the MessageListenerContainer One of: [DMLC] [SMLC]",
+ "defaultValue": "\"DMLC\"",
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "DMLC",
+ "SMLC"
+ ]
+ },
"camel.source.endpoint.prefetchCount": {
"name": "camel.source.endpoint.prefetchCount",
"description": "Tell the broker how many messages to send in a single request. Often this can be set quite high to improve throughput.",
@@ -263,6 +286,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.spring-rabbitmq.concurrentConsumers": {
+ "name": "camel.component.spring-rabbitmq.concurrentConsumers",
+ "description": "The number of consumers",
+ "defaultValue": "1",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.spring-rabbitmq.errorHandler": {
"name": "camel.component.spring-rabbitmq.errorHandler",
"description": "To use a custom ErrorHandler for handling exceptions from the message listener (consumer)",
@@ -275,6 +305,23 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.spring-rabbitmq.maxConcurrentConsumers": {
+ "name": "camel.component.spring-rabbitmq.maxConcurrentConsumers",
+ "description": "The maximum number of consumers (available only with SMLC)",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.spring-rabbitmq.messageListenerContainerType": {
+ "name": "camel.component.spring-rabbitmq.messageListenerContainerType",
+ "description": "The type of the MessageListenerContainer One of: [DMLC] [SMLC]",
+ "defaultValue": "\"DMLC\"",
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "DMLC",
+ "SMLC"
+ ]
+ },
"camel.component.spring-rabbitmq.prefetchCount": {
"name": "camel.component.spring-rabbitmq.prefetchCount",
"description": "Tell the broker how many messages to send to each consumer in a single request. Often this can be set quite high to improve throughput.",
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
index 9e183fa..e5674e6 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
@@ -30,7 +30,7 @@
"camel.sink.endpoint.autoCreateBucket": {
"name": "camel.sink.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -223,7 +223,7 @@
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
index 8621e81..d1169e8 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
@@ -30,7 +30,7 @@
"camel.source.endpoint.autoCreateBucket": {
"name": "camel.source.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -386,7 +386,7 @@
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
index 597aa87..1a99602 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-s3 sink connector supports 59 options, which are listed below.
| *camel.sink.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.sink.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
| *camel.sink.endpoint.policy* | The policy for this queue to set in the com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method. | null | false | MEDIUM
@@ -62,7 +62,7 @@ The camel-aws2-s3 sink connector supports 59 options, which are listed below.
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null | false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-s3.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
index 909c149..81fb275 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-s3 source connector supports 85 options, which are listed below.
| *camel.source.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.source.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.source.endpoint.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
| *camel.source.endpoint.policy* | The policy for this queue to set in the com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method. | null | false | MEDIUM
@@ -85,7 +85,7 @@ The camel-aws2-s3 source connector supports 85 options, which are listed below.
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null | false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-s3.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
index 86815fd..587fe04 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
@@ -35,7 +35,7 @@ public class CamelAws2s3SinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF = "camel.sink.endpoint.autoCreateBucket";
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.";
- public static final Boolean CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = false;
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_CONF = "camel.sink.endpoint.overrideEndpoint";
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DOC = "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option";
public static final Boolean CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT = false;
@@ -119,7 +119,7 @@ public class CamelAws2s3SinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF = "camel.component.aws2-s3.autoCreateBucket";
public static final String CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.";
- public static final Boolean CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = false;
public static final String CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_CONF = "camel.component.aws2-s3.configuration";
public static final String CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_DOC = "The component configuration";
public static final String CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_DEFAULT = null;
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
index 5b1608a..6c4edc9 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
@@ -37,7 +37,7 @@ public class CamelAws2s3SourceConnectorConfig
public static final String CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF = "camel.source.endpoint.autoCreateBucket";
public static final String CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.";
- public static final Boolean CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = true;
+ public static final Boolean CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = false;
public static final String CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_CONF = "camel.source.endpoint.overrideEndpoint";
public static final String CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DOC = "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option";
public static final Boolean CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT = false;
@@ -190,7 +190,7 @@ public class CamelAws2s3SourceConnectorConfig
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF = "camel.component.aws2-s3.autoCreateBucket";
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already.";
- public static final Boolean CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = true;
+ public static final Boolean CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = false;
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_CONF = "camel.component.aws2-s3.configuration";
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_DOC = "The component configuration";
public static final String CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_DEFAULT = null;
diff --git a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
index 7b059d4..0ef5538 100644
--- a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
+++ b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
@@ -24,7 +24,7 @@
"camel.sink.endpoint.autoCreateTopic": {
"name": "camel.sink.endpoint.autoCreateTopic",
"description": "Setting the autocreation of the topic",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -184,7 +184,7 @@
"camel.component.aws2-sns.autoCreateTopic": {
"name": "camel.component.aws2-sns.autoCreateTopic",
"description": "Setting the autocreation of the topic",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
index df40bba..f36dc00 100644
--- a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
@@ -33,7 +33,7 @@ The camel-aws2-sns sink connector supports 48 options, which are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.topicNameOrArn* | Topic name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonSNSClient* | To use the AmazonSNS as the client | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateTopic* | Setting the autocreation of the topic | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateTopic* | Setting the autocreation of the topic | false | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.kmsMasterKeyId* | The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK. | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then cre [...]
@@ -56,7 +56,7 @@ The camel-aws2-sns sink connector supports 48 options, which are listed below.
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false | MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sns.amazonSNSClient* | To use the AmazonSNS as the client | null | false | MEDIUM
-| *camel.component.aws2-sns.autoCreateTopic* | Setting the autocreation of the topic | true | false | MEDIUM
+| *camel.component.aws2-sns.autoCreateTopic* | Setting the autocreation of the topic | false | false | MEDIUM
| *camel.component.aws2-sns.configuration* | Component configuration | null | false | MEDIUM
| *camel.component.aws2-sns.kmsMasterKeyId* | The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK. | null | false | MEDIUM
| *camel.component.aws2-sns.lazyStartProducer* | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed the [...]
diff --git a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
index c816c82..321de5b 100644
--- a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
+++ b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
@@ -32,7 +32,7 @@ public class CamelAws2snsSinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_AMAZON_SNSCLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_AUTO_CREATE_TOPIC_CONF = "camel.sink.endpoint.autoCreateTopic";
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_AUTO_CREATE_TOPIC_DOC = "Setting the autocreation of the topic";
- public static final Boolean CAMEL_SINK_AWS2SNS_ENDPOINT_AUTO_CREATE_TOPIC_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2SNS_ENDPOINT_AUTO_CREATE_TOPIC_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_CONF = "camel.sink.endpoint.headerFilterStrategy";
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_DOC = "To use a custom HeaderFilterStrategy to map headers to/from Camel.";
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_HEADER_FILTER_STRATEGY_DEFAULT = null;
@@ -101,7 +101,7 @@ public class CamelAws2snsSinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_AMAZON_SNSCLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_AUTO_CREATE_TOPIC_CONF = "camel.component.aws2-sns.autoCreateTopic";
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_AUTO_CREATE_TOPIC_DOC = "Setting the autocreation of the topic";
- public static final Boolean CAMEL_SINK_AWS2SNS_COMPONENT_AUTO_CREATE_TOPIC_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2SNS_COMPONENT_AUTO_CREATE_TOPIC_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_CONF = "camel.component.aws2-sns.configuration";
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_DOC = "Component configuration";
public static final String CAMEL_SINK_AWS2SNS_COMPONENT_CONFIGURATION_DEFAULT = null;
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
index 33feaa7..8272ee5 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
@@ -31,7 +31,7 @@
"camel.sink.endpoint.autoCreateQueue": {
"name": "camel.sink.endpoint.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -235,7 +235,7 @@
"camel.component.aws2-sqs.autoCreateQueue": {
"name": "camel.component.aws2-sqs.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
index 22ad918..0a191ab 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
@@ -31,7 +31,7 @@
"camel.source.endpoint.autoCreateQueue": {
"name": "camel.source.endpoint.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -411,7 +411,7 @@
"camel.component.aws2-sqs.autoCreateQueue": {
"name": "camel.component.aws2-sqs.autoCreateQueue",
"description": "Setting the autocreation of the queue",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
index 9f58eef..80d7a6f 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-sqs sink connector supports 60 options, which are listed below.
| *camel.sink.path.queueNameOrArn* | Queue name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.sink.endpoint.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.sink.endpoint.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
@@ -63,7 +63,7 @@ The camel-aws2-sqs sink connector supports 60 options, which are listed below.
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sqs.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.component.aws2-sqs.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.component.aws2-sqs.configuration* | The AWS SQS default configuration | null | false | MEDIUM
| *camel.component.aws2-sqs.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sqs.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
index ba1b605..af08ebd 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-sqs source connector supports 93 options, which are listed below.
| *camel.source.path.queueNameOrArn* | Queue name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.source.endpoint.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.source.endpoint.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.source.endpoint.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.source.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.source.endpoint.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
@@ -89,7 +89,7 @@ The camel-aws2-sqs source connector supports 93 options, which are listed below.
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sqs.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.component.aws2-sqs.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.component.aws2-sqs.configuration* | The AWS SQS default configuration | null | false | MEDIUM
| *camel.component.aws2-sqs.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sqs.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
index 5a373ed..6c270be 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
@@ -35,7 +35,7 @@ public class CamelAws2sqsSinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_AMAZON_SQSCLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_CONF = "camel.sink.endpoint.autoCreateQueue";
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DOC = "Setting the autocreation of the queue";
- public static final Boolean CAMEL_SINK_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_CONF = "camel.sink.endpoint.headerFilterStrategy";
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_DOC = "To use a custom HeaderFilterStrategy to map headers to/from Camel.";
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_DEFAULT = null;
@@ -122,7 +122,7 @@ public class CamelAws2sqsSinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_AMAZON_SQSCLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_CONF = "camel.component.aws2-sqs.autoCreateQueue";
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DOC = "Setting the autocreation of the queue";
- public static final Boolean CAMEL_SINK_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_CONFIGURATION_CONF = "camel.component.aws2-sqs.configuration";
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_CONFIGURATION_DOC = "The AWS SQS default configuration";
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_CONFIGURATION_DEFAULT = null;
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
index e23696c..74372df 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
@@ -37,7 +37,7 @@ public class CamelAws2sqsSourceConnectorConfig
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_AMAZON_SQSCLIENT_DEFAULT = null;
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_CONF = "camel.source.endpoint.autoCreateQueue";
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DOC = "Setting the autocreation of the queue";
- public static final Boolean CAMEL_SOURCE_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SOURCE_AWS2SQS_ENDPOINT_AUTO_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_CONF = "camel.source.endpoint.headerFilterStrategy";
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_DOC = "To use a custom HeaderFilterStrategy to map headers to/from Camel.";
public static final String CAMEL_SOURCE_AWS2SQS_ENDPOINT_HEADER_FILTER_STRATEGY_DEFAULT = null;
@@ -202,7 +202,7 @@ public class CamelAws2sqsSourceConnectorConfig
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_AMAZON_SQSCLIENT_DEFAULT = null;
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_CONF = "camel.component.aws2-sqs.autoCreateQueue";
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DOC = "Setting the autocreation of the queue";
- public static final Boolean CAMEL_SOURCE_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SOURCE_AWS2SQS_COMPONENT_AUTO_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_CONFIGURATION_CONF = "camel.component.aws2-sqs.configuration";
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_CONFIGURATION_DOC = "The AWS SQS default configuration";
public static final String CAMEL_SOURCE_AWS2SQS_COMPONENT_CONFIGURATION_DEFAULT = null;
diff --git a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
index f65220a..fcf5581 100644
--- a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
+++ b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-sink.json
@@ -180,6 +180,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hostnameVerification": {
+ "name": "camel.sink.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.allowSerializedHeaders": {
"name": "camel.sink.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -506,6 +513,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.hostnameVerification": {
+ "name": "camel.component.netty-http.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.allowSerializedHeaders": {
"name": "camel.component.netty-http.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
index a0e8a6e..6ac3af1 100644
--- a/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
+++ b/connectors/camel-netty-http-kafka-connector/src/generated/resources/camel-netty-http-source.json
@@ -282,6 +282,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hostnameVerification": {
+ "name": "camel.source.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.allowSerializedHeaders": {
"name": "camel.source.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -683,6 +690,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty-http.hostnameVerification": {
+ "name": "camel.component.netty-http.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty-http.allowSerializedHeaders": {
"name": "camel.component.netty-http.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-sink-connector.adoc b/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-sink-connector.adoc
index b00f735..872422c 100644
--- a/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-sink-connector.adoc
+++ b/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSinkConn
----
-The camel-netty-http sink connector supports 111 options, which are listed below.
+The camel-netty-http sink connector supports 113 options, which are listed below.
@@ -56,6 +56,7 @@ The camel-netty-http sink connector supports 111 options, which are listed below
| *camel.sink.endpoint.producerPoolMinEvictableIdle* | Sets the minimum amount of time (value in millis) an object may sit idle in the pool before it is eligible for eviction by the idle object evictor. | 300000L | false | MEDIUM
| *camel.sink.endpoint.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.sink.endpoint.useRelativePath* | Sets whether to use a relative path in HTTP requests. | true | false | MEDIUM
+| *camel.sink.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.sink.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.sink.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.sink.endpoint.configuration* | To use a custom configured NettyHttpConfiguration for configuring this endpoint. | null | false | MEDIUM
@@ -106,6 +107,7 @@ The camel-netty-http sink connector supports 111 options, which are listed below
| *camel.component.netty-http.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.component.netty-http.udpConnectionless Sending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.component.netty-http.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.component.netty-http.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty-http.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty-http.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.netty-http.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-source-connector.adoc b/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-source-connector.adoc
index 9d9a9b3..5ea81c5 100644
--- a/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-source-connector.adoc
+++ b/connectors/camel-netty-http-kafka-connector/src/main/docs/camel-netty-http-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSourceCo
----
-The camel-netty-http source connector supports 131 options, which are listed below.
+The camel-netty-http source connector supports 133 options, which are listed below.
@@ -67,6 +67,7 @@ The camel-netty-http source connector supports 131 options, which are listed bel
| *camel.source.endpoint.traceEnabled* | Specifies whether to enable HTTP TRACE for this Netty HTTP consumer. By default TRACE is turned off. | false | false | MEDIUM
| *camel.source.endpoint.urlDecodeHeaders* | If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character. Notice this option is used by the default org.apache.camel.component.netty.http.NettyHttpBinding and therefore if you implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then you would need to decode the headers accordingly to this option. | false | false | MEDIUM
| *camel.source.endpoint.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.source.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.source.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.source.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.source.endpoint.configuration* | To use a custom configured NettyHttpConfiguration for configuring this endpoint. | null | false | MEDIUM
@@ -125,6 +126,7 @@ The camel-netty-http source connector supports 131 options, which are listed bel
| *camel.component.netty-http.serverExceptionCaught LogLevel* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.component.netty-http.serverInitializer Factory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.component.netty-http.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.component.netty-http.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty-http.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty-http.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.netty-http.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
index 9c8dae1..9596363 100644
--- a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
+++ b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
@@ -101,6 +101,9 @@ public class CamelNettyhttpSinkConnectorConfig
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_CONF = "camel.sink.endpoint.useRelativePath";
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_DOC = "Sets whether to use a relative path in HTTP requests.";
public static final Boolean CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_DEFAULT = true;
+ public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_CONF = "camel.sink.endpoint.hostnameVerification";
+ public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.sink.endpoint.allowSerializedHeaders";
public static final String CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -251,6 +254,9 @@ public class CamelNettyhttpSinkConnectorConfig
public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_CONF = "camel.component.netty-http.useByteBuf";
public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_DOC = "If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out.";
public static final Boolean CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_DEFAULT = false;
+ public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_CONF = "camel.component.netty-http.hostnameVerification";
+ public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.component.netty-http.allowSerializedHeaders";
public static final String CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -397,6 +403,7 @@ public class CamelNettyhttpSinkConnectorConfig
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_EVICTABLE_IDLE_CONF, ConfigDef.Type.LONG, CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_EVICTABLE_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_EVICTABLE_IDLE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_IDLE_CONF, ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_PRODUCER_POOL_MIN_IDLE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_USE_RELATIVE_PATH_DOC);
+ conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SINK_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_ENDPOINT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_NETTYHTTP_ENDPOINT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_ENDPOINT_CONFIGURATION_DOC);
@@ -447,6 +454,7 @@ public class CamelNettyhttpSinkConnectorConfig
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MIN_IDLE_CONF, ConfigDef.Type.INT, CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MIN_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_PRODUCER_POOL_MIN_IDLE_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_CONNECTIONLESS_SENDING_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_CONNECTIONLESS_SENDING_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_UDP_CONNECTIONLESS_SENDING_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_USE_BYTE_BUF_DOC);
+ conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_NETTYHTTP_COMPONENT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SINK_NETTYHTTP_COMPONENT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTYHTTP_COMPONENT_CHANNEL_GROUP_DOC);
diff --git a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
index 1da1aa7..d75bf26 100644
--- a/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
+++ b/connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
@@ -134,6 +134,9 @@ public class CamelNettyhttpSourceConnectorConfig
public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_CONF = "camel.source.endpoint.usingExecutorService";
public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_DOC = "Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.";
public static final Boolean CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_DEFAULT = true;
+ public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_CONF = "camel.source.endpoint.hostnameVerification";
+ public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.source.endpoint.allowSerializedHeaders";
public static final String CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -308,6 +311,9 @@ public class CamelNettyhttpSourceConnectorConfig
public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_CONF = "camel.component.netty-http.usingExecutorService";
public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_DOC = "Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.";
public static final Boolean CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_DEFAULT = true;
+ public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_CONF = "camel.component.netty-http.hostnameVerification";
+ public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.component.netty-http.allowSerializedHeaders";
public static final String CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -468,6 +474,7 @@ public class CamelNettyhttpSourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRACE_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRACE_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_TRACE_ENABLED_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_URL_DECODE_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_URL_DECODE_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_URL_DECODE_HEADERS_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_USING_EXECUTOR_SERVICE_DOC);
+ conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CHANNEL_GROUP_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_ENDPOINT_CONFIGURATION_DOC);
@@ -526,6 +533,7 @@ public class CamelNettyhttpSourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_INITIALIZER_FACTORY_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_INITIALIZER_FACTORY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_SERVER_INITIALIZER_FACTORY_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_USING_EXECUTOR_SERVICE_DOC);
+ conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SOURCE_NETTYHTTP_COMPONENT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTYHTTP_COMPONENT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTYHTTP_COMPONENT_CHANNEL_GROUP_DOC);
diff --git a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
index 04d72ab..7bcdce9 100644
--- a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
+++ b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-sink.json
@@ -160,6 +160,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hostnameVerification": {
+ "name": "camel.sink.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.allowSerializedHeaders": {
"name": "camel.sink.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -506,6 +513,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.hostnameVerification": {
+ "name": "camel.component.netty.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.allowSerializedHeaders": {
"name": "camel.component.netty.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
index 6a7e1ba..171e4aa 100644
--- a/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
+++ b/connectors/camel-netty-kafka-connector/src/generated/resources/camel-netty-source.json
@@ -221,6 +221,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hostnameVerification": {
+ "name": "camel.source.endpoint.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.allowSerializedHeaders": {
"name": "camel.source.endpoint.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
@@ -630,6 +637,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.netty.hostnameVerification": {
+ "name": "camel.component.netty.hostnameVerification",
+ "description": "To enable\/disable hostname verification on SSLEngine",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.netty.allowSerializedHeaders": {
"name": "camel.component.netty.allowSerializedHeaders",
"description": "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.",
diff --git a/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-sink-connector.adoc b/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-sink-connector.adoc
index 39d68f8..3cd0dc3 100644
--- a/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-sink-connector.adoc
+++ b/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.netty.CamelNettySinkConnector
----
-The camel-netty sink connector supports 107 options, which are listed below.
+The camel-netty sink connector supports 109 options, which are listed below.
@@ -53,6 +53,7 @@ The camel-netty sink connector supports 107 options, which are listed below.
| *camel.sink.endpoint.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.sink.endpoint.udpConnectionlessSending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.sink.endpoint.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.sink.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.sink.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.sink.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.sink.endpoint.nativeTransport* | Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: \http://netty.io/wiki/native-transports.html | false | false | MEDIUM
@@ -105,6 +106,7 @@ The camel-netty sink connector supports 107 options, which are listed below.
| *camel.component.netty.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.component.netty.udpConnectionlessSending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.component.netty.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.component.netty.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty.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.netty.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-source-connector.adoc b/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-source-connector.adoc
index ad91475..07a8199 100644
--- a/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-source-connector.adoc
+++ b/connectors/camel-netty-kafka-connector/src/main/docs/camel-netty-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.netty.CamelNettySourceConnector
----
-The camel-netty source connector supports 119 options, which are listed below.
+The camel-netty source connector supports 121 options, which are listed below.
@@ -58,6 +58,7 @@ The camel-netty source connector supports 119 options, which are listed below.
| *camel.source.endpoint.serverExceptionCaughtLog Level* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.source.endpoint.serverInitializerFactory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.source.endpoint.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.source.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.source.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.source.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.source.endpoint.nativeTransport* | Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: \http://netty.io/wiki/native-transports.html | false | false | MEDIUM
@@ -116,6 +117,7 @@ The camel-netty source connector supports 119 options, which are listed below.
| *camel.component.netty.serverExceptionCaughtLog Level* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.component.netty.serverInitializerFactory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.component.netty.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.component.netty.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty.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.netty.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
index 1cc2d98..1575e80 100644
--- a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
+++ b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySinkConnectorConfig.java
@@ -90,6 +90,9 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_CONF = "camel.sink.endpoint.useByteBuf";
public static final String CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_DOC = "If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out.";
public static final Boolean CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_DEFAULT = false;
+ public static final String CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_CONF = "camel.sink.endpoint.hostnameVerification";
+ public static final String CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.sink.endpoint.allowSerializedHeaders";
public static final String CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -246,6 +249,9 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig {
public static final String CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_CONF = "camel.component.netty.useByteBuf";
public static final String CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_DOC = "If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out.";
public static final Boolean CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_DEFAULT = false;
+ public static final String CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_CONF = "camel.component.netty.hostnameVerification";
+ public static final String CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.component.netty.allowSerializedHeaders";
public static final String CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -380,6 +386,7 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MIN_IDLE_CONF, ConfigDef.Type.INT, CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MIN_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_PRODUCER_POOL_MIN_IDLE_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_UDP_CONNECTIONLESS_SENDING_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_UDP_CONNECTIONLESS_SENDING_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_UDP_CONNECTIONLESS_SENDING_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_USE_BYTE_BUF_DOC);
+ conf.define(CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SINK_NETTY_ENDPOINT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_CHANNEL_GROUP_DOC);
conf.define(CAMEL_SINK_NETTY_ENDPOINT_NATIVE_TRANSPORT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_ENDPOINT_NATIVE_TRANSPORT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_ENDPOINT_NATIVE_TRANSPORT_DOC);
@@ -432,6 +439,7 @@ public class CamelNettySinkConnectorConfig extends CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MIN_IDLE_CONF, ConfigDef.Type.INT, CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MIN_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_PRODUCER_POOL_MIN_IDLE_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_UDP_CONNECTIONLESS_SENDING_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_UDP_CONNECTIONLESS_SENDING_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_UDP_CONNECTIONLESS_SENDING_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_USE_BYTE_BUF_DOC);
+ conf.define(CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_NETTY_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_NETTY_COMPONENT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SINK_NETTY_COMPONENT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_NETTY_COMPONENT_CHANNEL_GROUP_DOC);
diff --git a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
index cb72ef4..bcb1a1c 100644
--- a/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
+++ b/connectors/camel-netty-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/netty/CamelNettySourceConnectorConfig.java
@@ -107,6 +107,9 @@ public class CamelNettySourceConnectorConfig
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_CONF = "camel.source.endpoint.usingExecutorService";
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_DOC = "Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.";
public static final Boolean CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_DEFAULT = true;
+ public static final String CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_CONF = "camel.source.endpoint.hostnameVerification";
+ public static final String CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.source.endpoint.allowSerializedHeaders";
public static final String CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -281,6 +284,9 @@ public class CamelNettySourceConnectorConfig
public static final String CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_CONF = "camel.component.netty.usingExecutorService";
public static final String CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_DOC = "Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.";
public static final Boolean CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_DEFAULT = true;
+ public static final String CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_CONF = "camel.component.netty.hostnameVerification";
+ public static final String CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DOC = "To enable/disable hostname verification on SSLEngine";
+ public static final Boolean CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT = false;
public static final String CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF = "camel.component.netty.allowSerializedHeaders";
public static final String CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC = "Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level.";
public static final Boolean CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT = false;
@@ -423,6 +429,7 @@ public class CamelNettySourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_INITIALIZER_FACTORY_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_INITIALIZER_FACTORY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_SERVER_INITIALIZER_FACTORY_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_USING_EXECUTOR_SERVICE_DOC);
+ conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_ENDPOINT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_CHANNEL_GROUP_DOC);
conf.define(CAMEL_SOURCE_NETTY_ENDPOINT_NATIVE_TRANSPORT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_ENDPOINT_NATIVE_TRANSPORT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_ENDPOINT_NATIVE_TRANSPORT_DOC);
@@ -481,6 +488,7 @@ public class CamelNettySourceConnectorConfig
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_SERVER_EXCEPTION_CAUGHT_LOG_LEVEL_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_SERVER_INITIALIZER_FACTORY_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_COMPONENT_SERVER_INITIALIZER_FACTORY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_SERVER_INITIALIZER_FACTORY_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_USING_EXECUTOR_SERVICE_DOC);
+ conf.define(CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_HOSTNAME_VERIFICATION_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_ALLOW_SERIALIZED_HEADERS_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_NETTY_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SOURCE_NETTY_COMPONENT_CHANNEL_GROUP_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_NETTY_COMPONENT_CHANNEL_GROUP_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_NETTY_COMPONENT_CHANNEL_GROUP_DOC);
diff --git a/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json b/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
index adbe1f5..309945c 100644
--- a/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
+++ b/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
@@ -144,6 +144,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.concurrentConsumers": {
+ "name": "camel.source.endpoint.concurrentConsumers",
+ "description": "The number of consumers",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.exceptionHandler": {
"name": "camel.source.endpoint.exceptionHandler",
"description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -161,6 +167,23 @@
"InOptionalOut"
]
},
+ "camel.source.endpoint.maxConcurrentConsumers": {
+ "name": "camel.source.endpoint.maxConcurrentConsumers",
+ "description": "The maximum number of consumers (available only with SMLC)",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.messageListenerContainerType": {
+ "name": "camel.source.endpoint.messageListenerContainerType",
+ "description": "The type of the MessageListenerContainer One of: [DMLC] [SMLC]",
+ "defaultValue": "\"DMLC\"",
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "DMLC",
+ "SMLC"
+ ]
+ },
"camel.source.endpoint.prefetchCount": {
"name": "camel.source.endpoint.prefetchCount",
"description": "Tell the broker how many messages to send in a single request. Often this can be set quite high to improve throughput.",
@@ -263,6 +286,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.spring-rabbitmq.concurrentConsumers": {
+ "name": "camel.component.spring-rabbitmq.concurrentConsumers",
+ "description": "The number of consumers",
+ "defaultValue": "1",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.spring-rabbitmq.errorHandler": {
"name": "camel.component.spring-rabbitmq.errorHandler",
"description": "To use a custom ErrorHandler for handling exceptions from the message listener (consumer)",
@@ -275,6 +305,23 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.spring-rabbitmq.maxConcurrentConsumers": {
+ "name": "camel.component.spring-rabbitmq.maxConcurrentConsumers",
+ "description": "The maximum number of consumers (available only with SMLC)",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.component.spring-rabbitmq.messageListenerContainerType": {
+ "name": "camel.component.spring-rabbitmq.messageListenerContainerType",
+ "description": "The type of the MessageListenerContainer One of: [DMLC] [SMLC]",
+ "defaultValue": "\"DMLC\"",
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "DMLC",
+ "SMLC"
+ ]
+ },
"camel.component.spring-rabbitmq.prefetchCount": {
"name": "camel.component.spring-rabbitmq.prefetchCount",
"description": "Tell the broker how many messages to send to each consumer in a single request. Often this can be set quite high to improve throughput.",
diff --git a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
index c3dcc6a..467a171 100644
--- a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
+++ b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.springrabbitmq.CamelSpringrabbit
----
-The camel-spring-rabbitmq source connector supports 44 options, which are listed below.
+The camel-spring-rabbitmq source connector supports 50 options, which are listed below.
@@ -49,8 +49,11 @@ The camel-spring-rabbitmq source connector supports 44 options, which are listed
| *camel.source.endpoint.exclusive* | Set to true for an exclusive consumer | false | false | MEDIUM
| *camel.source.endpoint.noLocal* | Set to true for an no-local consumer | false | false | MEDIUM
| *camel.source.endpoint.queues* | The queue(s) to use for consuming messages. Multiple queue names can be separated by comma. If none has been configured then Camel will generate an unique id as the queue name for the consumer. | null | false | MEDIUM
+| *camel.source.endpoint.concurrentConsumers* | The number of consumers | null | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null | false | MEDIUM
+| *camel.source.endpoint.maxConcurrentConsumers* | The maximum number of consumers (available only with SMLC) | null | false | MEDIUM
+| *camel.source.endpoint.messageListenerContainerType* | The type of the MessageListenerContainer One of: [DMLC] [SMLC] | "DMLC" | false | MEDIUM
| *camel.source.endpoint.prefetchCount* | Tell the broker how many messages to send in a single request. Often this can be set quite high to improve throughput. | null | false | MEDIUM
| *camel.source.endpoint.args* | Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each element: arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange. arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl argument: args=arg.queue.x-message-ttl=60000 | null | false | MEDIUM
| *camel.source.endpoint.messageConverter* | To use a custom MessageConverter so you can be in control how to map to/from a org.springframework.amqp.core.Message. | null | false | MEDIUM
@@ -66,8 +69,11 @@ The camel-spring-rabbitmq source connector supports 44 options, which are listed
| *camel.component.spring-rabbitmq.deadLetterExchange Type* | The type of the dead letter exchange One of: [direct] [fanout] [headers] [topic] | "direct" | false | MEDIUM
| *camel.component.spring-rabbitmq.deadLetterQueue* | The name of the dead letter queue | null | false | MEDIUM
| *camel.component.spring-rabbitmq.deadLetterRouting Key* | The routing key for the dead letter exchange | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.concurrent Consumers* | The number of consumers | 1 | false | MEDIUM
| *camel.component.spring-rabbitmq.errorHandler* | To use a custom ErrorHandler for handling exceptions from the message listener (consumer) | null | false | MEDIUM
| *camel.component.spring-rabbitmq.listenerContainer Factory* | To use a custom factory for creating and configuring ListenerContainer to be used by the consumer for receiving messages | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.maxConcurrent Consumers* | The maximum number of consumers (available only with SMLC) | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.messageListener ContainerType* | The type of the MessageListenerContainer One of: [DMLC] [SMLC] | "DMLC" | false | MEDIUM
| *camel.component.spring-rabbitmq.prefetchCount* | Tell the broker how many messages to send to each consumer in a single request. Often this can be set quite high to improve throughput. | 250 | false | MEDIUM
| *camel.component.spring-rabbitmq.shutdownTimeout* | The time to wait for workers in milliseconds after the container is stopped. If any workers are active when the shutdown signal comes they will be allowed to finish processing as long as they can finish within this timeout. | 5000L | false | MEDIUM
| *camel.component.spring-rabbitmq.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
diff --git a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
index 7fd9c41..d6cb6c9 100644
--- a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
+++ b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
@@ -80,12 +80,21 @@ public class CamelSpringrabbitmqSourceConnectorConfig
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_CONF = "camel.source.endpoint.queues";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DOC = "The queue(s) to use for consuming messages. Multiple queue names can be separated by comma. If none has been configured then Camel will generate an unique id as the queue name for the consumer.";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_CONF = "camel.source.endpoint.concurrentConsumers";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_DOC = "The number of consumers";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_DEFAULT = null;
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_CONF = "camel.source.endpoint.exceptionHandler";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DOC = "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DEFAULT = null;
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_CONF = "camel.source.endpoint.exchangePattern";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DOC = "Sets the exchange pattern when the consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut]";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_CONF = "camel.source.endpoint.maxConcurrentConsumers";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_DOC = "The maximum number of consumers (available only with SMLC)";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_CONF = "camel.source.endpoint.messageListenerContainerType";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_DOC = "The type of the MessageListenerContainer One of: [DMLC] [SMLC]";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_DEFAULT = "DMLC";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_CONF = "camel.source.endpoint.prefetchCount";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DOC = "Tell the broker how many messages to send in a single request. Often this can be set quite high to improve throughput.";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DEFAULT = null;
@@ -131,12 +140,21 @@ public class CamelSpringrabbitmqSourceConnectorConfig
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_CONF = "camel.component.spring-rabbitmq.deadLetterRoutingKey";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_DOC = "The routing key for the dead letter exchange";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_CONF = "camel.component.spring-rabbitmq.concurrentConsumers";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_DOC = "The number of consumers";
+ public static final Integer CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_DEFAULT = 1;
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_CONF = "camel.component.spring-rabbitmq.errorHandler";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_DOC = "To use a custom ErrorHandler for handling exceptions from the message listener (consumer)";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_DEFAULT = null;
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_CONF = "camel.component.spring-rabbitmq.listenerContainerFactory";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_DOC = "To use a custom factory for creating and configuring ListenerContainer to be used by the consumer for receiving messages";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_CONF = "camel.component.spring-rabbitmq.maxConcurrentConsumers";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_DOC = "The maximum number of consumers (available only with SMLC)";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_DEFAULT = null;
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_CONF = "camel.component.spring-rabbitmq.messageListenerContainerType";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_DOC = "The type of the MessageListenerContainer One of: [DMLC] [SMLC]";
+ public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_DEFAULT = "DMLC";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_CONF = "camel.component.spring-rabbitmq.prefetchCount";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_DOC = "Tell the broker how many messages to send to each consumer in a single request. Often this can be set quite high to improve throughput.";
public static final Integer CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_DEFAULT = 250;
@@ -190,8 +208,11 @@ public class CamelSpringrabbitmqSourceConnectorConfig
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCLUSIVE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCLUSIVE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCLUSIVE_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_NO_LOCAL_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_NO_LOCAL_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_NO_LOCAL_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_CONCURRENT_CONSUMERS_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MAX_CONCURRENT_CONSUMERS_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_LISTENER_CONTAINER_TYPE_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_DOC);
@@ -207,8 +228,11 @@ public class CamelSpringrabbitmqSourceConnectorConfig
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_EXCHANGE_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_EXCHANGE_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_EXCHANGE_TYPE_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_QUEUE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_QUEUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_QUEUE_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_DEAD_LETTER_ROUTING_KEY_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_CONCURRENT_CONSUMERS_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_LISTENER_CONTAINER_FACTORY_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MAX_CONCURRENT_CONSUMERS_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_MESSAGE_LISTENER_CONTAINER_TYPE_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_CONF, ConfigDef.Type.INT, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_PREFETCH_COUNT_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_SHUTDOWN_TIMEOUT_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_SHUTDOWN_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_SHUTDOWN_TIMEOUT_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_AUTOWIRED_ENABLED_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_AUTOWIRED_ENABLED_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_COMPONENT_AUTOWIRED_ENABLED_DOC);
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index f8d3083..dbaeb55 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -70,6 +70,50 @@
** 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-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
@@ -115,9 +159,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 4e7893c..2e11eaf 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: 335
+Number of Camel Kafka connectors: 357
[width="100%",cols="4,1,1,1,1,1",options="header"]
|===
@@ -27,6 +27,26 @@ Number of Camel Kafka connectors: 335
| *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-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]
@@ -48,7 +68,9 @@ Number of Camel Kafka connectors: 335
| *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-aws2-s3-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
index 597aa87..1a99602 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-s3 sink connector supports 59 options, which are listed below.
| *camel.sink.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.sink.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
| *camel.sink.endpoint.policy* | The policy for this queue to set in the com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method. | null | false | MEDIUM
@@ -62,7 +62,7 @@ The camel-aws2-s3 sink connector supports 59 options, which are listed below.
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null | false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-s3.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
index 909c149..81fb275 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-s3 source connector supports 85 options, which are listed below.
| *camel.source.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.source.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.source.endpoint.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
| *camel.source.endpoint.policy* | The policy for this queue to set in the com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method. | null | false | MEDIUM
@@ -85,7 +85,7 @@ The camel-aws2-s3 source connector supports 85 options, which are listed below.
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request, used mainly in createDownloadLink operation | null | false | MEDIUM
-| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | true | false | MEDIUM
+| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled and it will create the destinationBucket if it doesn't exist already. | false | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null | false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-s3.pojoRequest* | If we want to use a POJO request as body or not | false | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
index df40bba..f36dc00 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
@@ -33,7 +33,7 @@ The camel-aws2-sns sink connector supports 48 options, which are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.topicNameOrArn* | Topic name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonSNSClient* | To use the AmazonSNS as the client | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateTopic* | Setting the autocreation of the topic | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateTopic* | Setting the autocreation of the topic | false | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.kmsMasterKeyId* | The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK. | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then cre [...]
@@ -56,7 +56,7 @@ The camel-aws2-sns sink connector supports 48 options, which are listed below.
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false | MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sns.amazonSNSClient* | To use the AmazonSNS as the client | null | false | MEDIUM
-| *camel.component.aws2-sns.autoCreateTopic* | Setting the autocreation of the topic | true | false | MEDIUM
+| *camel.component.aws2-sns.autoCreateTopic* | Setting the autocreation of the topic | false | false | MEDIUM
| *camel.component.aws2-sns.configuration* | Component configuration | null | false | MEDIUM
| *camel.component.aws2-sns.kmsMasterKeyId* | The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK. | null | false | MEDIUM
| *camel.component.aws2-sns.lazyStartProducer* | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed the [...]
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
index 9f58eef..80d7a6f 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-sqs sink connector supports 60 options, which are listed below.
| *camel.sink.path.queueNameOrArn* | Queue name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.sink.endpoint.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.sink.endpoint.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.sink.endpoint.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.sink.endpoint.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
@@ -63,7 +63,7 @@ The camel-aws2-sqs sink connector supports 60 options, which are listed below.
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sqs.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.component.aws2-sqs.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.component.aws2-sqs.configuration* | The AWS SQS default configuration | null | false | MEDIUM
| *camel.component.aws2-sqs.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sqs.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
index ba1b605..af08ebd 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
@@ -34,7 +34,7 @@ The camel-aws2-sqs source connector supports 93 options, which are listed below.
| *camel.source.path.queueNameOrArn* | Queue name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.source.endpoint.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.source.endpoint.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.source.endpoint.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.source.endpoint.headerFilterStrategy* | To use a custom HeaderFilterStrategy to map headers to/from Camel. | null | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.source.endpoint.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
@@ -89,7 +89,7 @@ The camel-aws2-sqs source connector supports 93 options, which are listed below.
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false | MEDIUM
| *camel.component.aws2-sqs.amazonAWSHost* | The hostname of the Amazon AWS cloud. | "amazonaws.com" | false | MEDIUM
| *camel.component.aws2-sqs.amazonSQSClient* | To use the AmazonSQS as client | null | false | MEDIUM
-| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | true | false | MEDIUM
+| *camel.component.aws2-sqs.autoCreateQueue* | Setting the autocreation of the queue | false | false | MEDIUM
| *camel.component.aws2-sqs.configuration* | The AWS SQS default configuration | null | false | MEDIUM
| *camel.component.aws2-sqs.overrideEndpoint* | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sqs.protocol* | The underlying protocol used to communicate with SQS | "https" | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-sink-connector.adoc
index b00f735..872422c 100644
--- a/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSinkConn
----
-The camel-netty-http sink connector supports 111 options, which are listed below.
+The camel-netty-http sink connector supports 113 options, which are listed below.
@@ -56,6 +56,7 @@ The camel-netty-http sink connector supports 111 options, which are listed below
| *camel.sink.endpoint.producerPoolMinEvictableIdle* | Sets the minimum amount of time (value in millis) an object may sit idle in the pool before it is eligible for eviction by the idle object evictor. | 300000L | false | MEDIUM
| *camel.sink.endpoint.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.sink.endpoint.useRelativePath* | Sets whether to use a relative path in HTTP requests. | true | false | MEDIUM
+| *camel.sink.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.sink.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.sink.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.sink.endpoint.configuration* | To use a custom configured NettyHttpConfiguration for configuring this endpoint. | null | false | MEDIUM
@@ -106,6 +107,7 @@ The camel-netty-http sink connector supports 111 options, which are listed below
| *camel.component.netty-http.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.component.netty-http.udpConnectionless Sending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.component.netty-http.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.component.netty-http.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty-http.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty-http.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.netty-http.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-source-connector.adoc
index 9d9a9b3..5ea81c5 100644
--- a/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-netty-http-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSourceCo
----
-The camel-netty-http source connector supports 131 options, which are listed below.
+The camel-netty-http source connector supports 133 options, which are listed below.
@@ -67,6 +67,7 @@ The camel-netty-http source connector supports 131 options, which are listed bel
| *camel.source.endpoint.traceEnabled* | Specifies whether to enable HTTP TRACE for this Netty HTTP consumer. By default TRACE is turned off. | false | false | MEDIUM
| *camel.source.endpoint.urlDecodeHeaders* | If this option is enabled, then during binding from Netty to Camel Message then the header values will be URL decoded (eg %20 will be a space character. Notice this option is used by the default org.apache.camel.component.netty.http.NettyHttpBinding and therefore if you implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then you would need to decode the headers accordingly to this option. | false | false | MEDIUM
| *camel.source.endpoint.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.source.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.source.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.source.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.source.endpoint.configuration* | To use a custom configured NettyHttpConfiguration for configuring this endpoint. | null | false | MEDIUM
@@ -125,6 +126,7 @@ The camel-netty-http source connector supports 131 options, which are listed bel
| *camel.component.netty-http.serverExceptionCaught LogLevel* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.component.netty-http.serverInitializer Factory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.component.netty-http.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.component.netty-http.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty-http.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty-http.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.netty-http.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-netty-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-netty-kafka-sink-connector.adoc
index 39d68f8..3cd0dc3 100644
--- a/docs/modules/ROOT/pages/connectors/camel-netty-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-netty-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.netty.CamelNettySinkConnector
----
-The camel-netty sink connector supports 107 options, which are listed below.
+The camel-netty sink connector supports 109 options, which are listed below.
@@ -53,6 +53,7 @@ The camel-netty sink connector supports 107 options, which are listed below.
| *camel.sink.endpoint.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.sink.endpoint.udpConnectionlessSending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.sink.endpoint.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.sink.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.sink.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.sink.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.sink.endpoint.nativeTransport* | Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: \http://netty.io/wiki/native-transports.html | false | false | MEDIUM
@@ -105,6 +106,7 @@ The camel-netty sink connector supports 107 options, which are listed below.
| *camel.component.netty.producerPoolMinIdle* | Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects. | null | false | MEDIUM
| *camel.component.netty.udpConnectionlessSending* | This option supports connection less udp sending which is a real fire and forget. A connected udp send receive the PortUnreachableException if no one is listen on the receiving port. | false | false | MEDIUM
| *camel.component.netty.useByteBuf* | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | false | MEDIUM
+| *camel.component.netty.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty.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.netty.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-netty-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-netty-kafka-source-connector.adoc
index ad91475..07a8199 100644
--- a/docs/modules/ROOT/pages/connectors/camel-netty-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-netty-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.netty.CamelNettySourceConnector
----
-The camel-netty source connector supports 119 options, which are listed below.
+The camel-netty source connector supports 121 options, which are listed below.
@@ -58,6 +58,7 @@ The camel-netty source connector supports 119 options, which are listed below.
| *camel.source.endpoint.serverExceptionCaughtLog Level* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.source.endpoint.serverInitializerFactory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.source.endpoint.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.source.endpoint.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.source.endpoint.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.source.endpoint.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
| *camel.source.endpoint.nativeTransport* | Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: \http://netty.io/wiki/native-transports.html | false | false | MEDIUM
@@ -116,6 +117,7 @@ The camel-netty source connector supports 119 options, which are listed below.
| *camel.component.netty.serverExceptionCaughtLog Level* | If the server (NettyConsumer) catches an exception then its logged using this logging level. One of: [TRACE] [DEBUG] [INFO] [WARN] [ERROR] [OFF] | "WARN" | false | MEDIUM
| *camel.component.netty.serverInitializerFactory* | To use a custom ServerInitializerFactory | null | false | MEDIUM
| *camel.component.netty.usingExecutorService* | Whether to use ordered thread pool, to ensure events are processed orderly on the same channel. | true | false | MEDIUM
+| *camel.component.netty.hostnameVerification* | To enable/disable hostname verification on SSLEngine | false | false | MEDIUM
| *camel.component.netty.allowSerializedHeaders* | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | false | MEDIUM
| *camel.component.netty.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.netty.channelGroup* | To use a explicit ChannelGroup. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
index c3dcc6a..467a171 100644
--- a/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.springrabbitmq.CamelSpringrabbit
----
-The camel-spring-rabbitmq source connector supports 44 options, which are listed below.
+The camel-spring-rabbitmq source connector supports 50 options, which are listed below.
@@ -49,8 +49,11 @@ The camel-spring-rabbitmq source connector supports 44 options, which are listed
| *camel.source.endpoint.exclusive* | Set to true for an exclusive consumer | false | false | MEDIUM
| *camel.source.endpoint.noLocal* | Set to true for an no-local consumer | false | false | MEDIUM
| *camel.source.endpoint.queues* | The queue(s) to use for consuming messages. Multiple queue names can be separated by comma. If none has been configured then Camel will generate an unique id as the queue name for the consumer. | null | false | MEDIUM
+| *camel.source.endpoint.concurrentConsumers* | The number of consumers | null | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null | false | MEDIUM
+| *camel.source.endpoint.maxConcurrentConsumers* | The maximum number of consumers (available only with SMLC) | null | false | MEDIUM
+| *camel.source.endpoint.messageListenerContainerType* | The type of the MessageListenerContainer One of: [DMLC] [SMLC] | "DMLC" | false | MEDIUM
| *camel.source.endpoint.prefetchCount* | Tell the broker how many messages to send in a single request. Often this can be set quite high to improve throughput. | null | false | MEDIUM
| *camel.source.endpoint.args* | Specify arguments for configuring the different RabbitMQ concepts, a different prefix is required for each element: arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange. arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl argument: args=arg.queue.x-message-ttl=60000 | null | false | MEDIUM
| *camel.source.endpoint.messageConverter* | To use a custom MessageConverter so you can be in control how to map to/from a org.springframework.amqp.core.Message. | null | false | MEDIUM
@@ -66,8 +69,11 @@ The camel-spring-rabbitmq source connector supports 44 options, which are listed
| *camel.component.spring-rabbitmq.deadLetterExchange Type* | The type of the dead letter exchange One of: [direct] [fanout] [headers] [topic] | "direct" | false | MEDIUM
| *camel.component.spring-rabbitmq.deadLetterQueue* | The name of the dead letter queue | null | false | MEDIUM
| *camel.component.spring-rabbitmq.deadLetterRouting Key* | The routing key for the dead letter exchange | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.concurrent Consumers* | The number of consumers | 1 | false | MEDIUM
| *camel.component.spring-rabbitmq.errorHandler* | To use a custom ErrorHandler for handling exceptions from the message listener (consumer) | null | false | MEDIUM
| *camel.component.spring-rabbitmq.listenerContainer Factory* | To use a custom factory for creating and configuring ListenerContainer to be used by the consumer for receiving messages | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.maxConcurrent Consumers* | The maximum number of consumers (available only with SMLC) | null | false | MEDIUM
+| *camel.component.spring-rabbitmq.messageListener ContainerType* | The type of the MessageListenerContainer One of: [DMLC] [SMLC] | "DMLC" | false | MEDIUM
| *camel.component.spring-rabbitmq.prefetchCount* | Tell the broker how many messages to send to each consumer in a single request. Often this can be set quite high to improve throughput. | 250 | false | MEDIUM
| *camel.component.spring-rabbitmq.shutdownTimeout* | The time to wait for workers in milliseconds after the container is stopped. If any workers are active when the shutdown signal comes they will be allowed to finish processing as long as they can finish within this timeout. | 5000L | false | MEDIUM
| *camel.component.spring-rabbitmq.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