You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/04/22 05:07:07 UTC
[camel-kafka-connector] branch main updated: [create-pull-request]
automated change
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 96ff5dd [create-pull-request] automated change
96ff5dd is described below
commit 96ff5dd4e26d5ff152cc2d2cf95c9d2dadd2d683
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Thu Apr 22 04:46:00 2021 +0000
[create-pull-request] automated change
---
.../connectors/camel-azure-eventhubs-sink.json | 14 --------------
.../connectors/camel-azure-eventhubs-source.json | 14 --------------
.../connectors/camel-azure-storage-blob-sink.json | 14 --------------
.../connectors/camel-azure-storage-blob-source.json | 14 --------------
.../connectors/camel-azure-storage-queue-sink.json | 18 ++----------------
.../connectors/camel-azure-storage-queue-source.json | 14 --------------
.../resources/connectors/camel-github-source.json | 7 +++++++
.../resources/connectors/camel-kamelet-sink.json | 2 +-
.../resources/connectors/camel-kamelet-source.json | 2 +-
.../resources/connectors/camel-vertx-http-sink.json | 16 ++--------------
.../resources/descriptors/connectors.properties | 1 -
.../resources/camel-azure-eventhubs-sink.json | 14 --------------
.../resources/camel-azure-eventhubs-source.json | 14 --------------
.../camel-azure-eventhubs-kafka-sink-connector.adoc | 4 +---
.../camel-azure-eventhubs-kafka-source-connector.adoc | 4 +---
.../CamelAzureeventhubsSinkConnectorConfig.java | 8 --------
.../CamelAzureeventhubsSourceConnectorConfig.java | 8 --------
.../resources/camel-azure-storage-blob-sink.json | 14 --------------
.../resources/camel-azure-storage-blob-source.json | 14 --------------
.../camel-azure-storage-blob-kafka-sink-connector.adoc | 4 +---
...amel-azure-storage-blob-kafka-source-connector.adoc | 4 +---
.../CamelAzurestorageblobSinkConnectorConfig.java | 8 --------
.../CamelAzurestorageblobSourceConnectorConfig.java | 8 --------
.../resources/camel-azure-storage-queue-sink.json | 18 ++----------------
.../resources/camel-azure-storage-queue-source.json | 14 --------------
...camel-azure-storage-queue-kafka-sink-connector.adoc | 8 +++-----
...mel-azure-storage-queue-kafka-source-connector.adoc | 4 +---
.../CamelAzurestoragequeueSinkConnectorConfig.java | 12 ++----------
.../CamelAzurestoragequeueSourceConnectorConfig.java | 8 --------
.../src/generated/resources/camel-github-source.json | 7 +++++++
.../main/docs/camel-github-kafka-source-connector.adoc | 3 ++-
.../github/CamelGithubSourceConnectorConfig.java | 4 ++++
.../src/generated/resources/camel-kamelet-sink.json | 2 +-
.../src/generated/resources/camel-kamelet-source.json | 2 +-
.../main/docs/camel-kamelet-kafka-sink-connector.adoc | 2 +-
.../docs/camel-kamelet-kafka-source-connector.adoc | 2 +-
.../src/generated/resources/camel-vertx-http-sink.json | 16 ++--------------
.../docs/camel-vertx-http-kafka-sink-connector.adoc | 2 +-
.../vertxhttp/CamelVertxhttpSinkConnectorConfig.java | 2 +-
docs/modules/ROOT/nav.adoc | 2 --
docs/modules/ROOT/pages/connectors.adoc | 3 +--
.../camel-azure-eventhubs-kafka-sink-connector.adoc | 4 +---
.../camel-azure-eventhubs-kafka-source-connector.adoc | 4 +---
.../camel-azure-storage-blob-kafka-sink-connector.adoc | 4 +---
...amel-azure-storage-blob-kafka-source-connector.adoc | 4 +---
...camel-azure-storage-queue-kafka-sink-connector.adoc | 8 +++-----
...mel-azure-storage-queue-kafka-source-connector.adoc | 4 +---
.../camel-github-kafka-source-connector.adoc | 3 ++-
.../connectors/camel-kamelet-kafka-sink-connector.adoc | 2 +-
.../camel-kamelet-kafka-source-connector.adoc | 2 +-
.../camel-vertx-http-kafka-sink-connector.adoc | 2 +-
51 files changed, 60 insertions(+), 308 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-sink.json
index 538f823..cb004e4 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-sink.json
@@ -38,13 +38,6 @@
"AmqpWebSockets"
]
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
"description": "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 creating and starting the pr [...]
@@ -105,13 +98,6 @@
"AmqpWebSockets"
]
},
- "camel.component.azure-eventhubs.autoDiscoverClient": {
- "name": "camel.component.azure-eventhubs.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-eventhubs.configuration": {
"name": "camel.component.azure-eventhubs.configuration",
"description": "The component configurations",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-source.json
index 909a4f9..0c2d777 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-eventhubs-source.json
@@ -38,13 +38,6 @@
"AmqpWebSockets"
]
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.blobAccessKey": {
"name": "camel.source.endpoint.blobAccessKey",
"description": "In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services",
@@ -155,13 +148,6 @@
"AmqpWebSockets"
]
},
- "camel.component.azure-eventhubs.autoDiscoverClient": {
- "name": "camel.component.azure-eventhubs.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-eventhubs.configuration": {
"name": "camel.component.azure-eventhubs.configuration",
"description": "The component configurations",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-sink.json
index c028610..fc66bfe 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-sink.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.blobName": {
"name": "camel.sink.endpoint.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
@@ -222,13 +215,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-blob.autoDiscoverClient": {
- "name": "camel.component.azure-storage-blob.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-blob.blobName": {
"name": "camel.component.azure-storage-blob.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-source.json
index d39070a..f849a32 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-source.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.blobName": {
"name": "camel.source.endpoint.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
@@ -274,13 +267,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-blob.autoDiscoverClient": {
- "name": "camel.component.azure-storage-blob.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-blob.blobName": {
"name": "camel.component.azure-storage-blob.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-sink.json
index a51fb7b..c58c9c2 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-sink.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.serviceClient": {
"name": "camel.sink.endpoint.serviceClient",
"description": "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of the account, and ret [...]
@@ -37,7 +30,7 @@
"camel.sink.endpoint.createQueue": {
"name": "camel.sink.endpoint.createQueue",
"description": "When is set to true, the queue will be automatically created when sending messages to the queue.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -114,13 +107,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-queue.autoDiscoverClient": {
- "name": "camel.component.azure-storage-queue.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-queue.configuration": {
"name": "camel.component.azure-storage-queue.configuration",
"description": "The component configurations",
@@ -136,7 +122,7 @@
"camel.component.azure-storage-queue.createQueue": {
"name": "camel.component.azure-storage-queue.createQueue",
"description": "When is set to true, the queue will be automatically created when sending messages to the queue.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-source.json
index 1527b3c..7c4571b 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-queue-source.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.serviceClient": {
"name": "camel.source.endpoint.serviceClient",
"description": "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of the account, and ret [...]
@@ -230,13 +223,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-queue.autoDiscoverClient": {
- "name": "camel.component.azure-storage-queue.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-queue.configuration": {
"name": "camel.component.azure-storage-queue.configuration",
"description": "The component configurations",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source.json
index 3447dfd..0c35219 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source.json
@@ -33,6 +33,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.path.startingSha": {
+ "name": "camel.source.path.startingSha",
+ "description": "The starting sha to use for polling commits with the commit consumer. The value can either be a sha for the sha to start from, or use beginning to start from the beginning, or last to start from the last commit.",
+ "defaultValue": "\"last\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.repoName": {
"name": "camel.source.endpoint.repoName",
"description": "GitHub repository name",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
index 5e5aa7c..ffdee48 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
@@ -6,7 +6,7 @@
"id": "camel-kamelet-sink",
"type": "sink",
"version": "0.10.0-SNAPSHOT",
- "description": "The Kamelet Component provides support for interacting with the Camel Route Template engine"
+ "description": "To call Kamelets"
},
"properties": {
"camel.sink.path.templateId": {
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
index 57eed6b..4322644 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
@@ -6,7 +6,7 @@
"id": "camel-kamelet-source",
"type": "source",
"version": "0.10.0-SNAPSHOT",
- "description": "The Kamelet Component provides support for interacting with the Camel Route Template engine"
+ "description": "To call Kamelets"
},
"properties": {
"camel.source.path.templateId": {
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-http-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-http-sink.json
index 5a6f04a..0a7947c 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-http-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-vertx-http-sink.json
@@ -38,21 +38,9 @@
},
"camel.sink.endpoint.httpMethod": {
"name": "camel.sink.endpoint.httpMethod",
- "description": "The HTTP method to use. The HttpMethod header cannot override this option if set One of: [OPTIONS] [GET] [HEAD] [POST] [PUT] [DELETE] [TRACE] [CONNECT] [PATCH] [OTHER]",
+ "description": "The HTTP method to use. The HttpMethod header cannot override this option if set",
"priority": "MEDIUM",
- "required": "false",
- "enum": [
- "OPTIONS",
- "GET",
- "HEAD",
- "POST",
- "PUT",
- "DELETE",
- "TRACE",
- "CONNECT",
- "PATCH",
- "OTHER"
- ]
+ "required": "false"
},
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties b/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
index 870144b..eeda94f 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
+++ b/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
@@ -104,7 +104,6 @@ camel-couchdb-sink
camel-cql-source
camel-cql-sink
camel-cron-source
-camel-crypto-cms-sink
camel-crypto-sink
camel-cxf-source
camel-cxf-sink
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-sink.json b/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-sink.json
index 538f823..cb004e4 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-sink.json
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-sink.json
@@ -38,13 +38,6 @@
"AmqpWebSockets"
]
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
"description": "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 creating and starting the pr [...]
@@ -105,13 +98,6 @@
"AmqpWebSockets"
]
},
- "camel.component.azure-eventhubs.autoDiscoverClient": {
- "name": "camel.component.azure-eventhubs.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-eventhubs.configuration": {
"name": "camel.component.azure-eventhubs.configuration",
"description": "The component configurations",
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-source.json b/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-source.json
index 909a4f9..0c2d777 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-source.json
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/generated/resources/camel-azure-eventhubs-source.json
@@ -38,13 +38,6 @@
"AmqpWebSockets"
]
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.blobAccessKey": {
"name": "camel.source.endpoint.blobAccessKey",
"description": "In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services",
@@ -155,13 +148,6 @@
"AmqpWebSockets"
]
},
- "camel.component.azure-eventhubs.autoDiscoverClient": {
- "name": "camel.component.azure-eventhubs.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-eventhubs.configuration": {
"name": "camel.component.azure-eventhubs.configuration",
"description": "The component configurations",
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-sink-connector.adoc b/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-sink-connector.adoc
index 03e6012..ee436a1 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-sink-connector.adoc
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azureeventhubs.CamelAzureeventhu
----
-The camel-azure-eventhubs sink connector supports 24 options, which are listed below.
+The camel-azure-eventhubs sink connector supports 22 options, which are listed below.
@@ -35,7 +35,6 @@ The camel-azure-eventhubs sink connector supports 24 options, which are listed b
| *camel.sink.path.eventHubName* | EventHubs name under a specific namcespace | null | false | MEDIUM
| *camel.sink.endpoint.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.sink.endpoint.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | 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 [...]
| *camel.sink.endpoint.partitionId* | Sets the identifier of the Event Hub partition that the events will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition. | null | false | MEDIUM
| *camel.sink.endpoint.partitionKey* | Sets a hashing key to be provided for the batch of events, which instructs the Event Hubs service to map this key to a specific partition. The selection of a partition is stable for a given partition hashing key. Should any other batches of events be sent using the same exact partition hashing key, the Event Hubs service will route them all to the same partition. This should be specified only when there is a need to group events by partition, but th [...]
@@ -45,7 +44,6 @@ The camel-azure-eventhubs sink connector supports 24 options, which are listed b
| *camel.sink.endpoint.sharedAccessName* | The name you chose for your EventHubs SAS keys | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.component.azure-eventhubs.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-eventhubs.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-eventhubs.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 proces [...]
| *camel.component.azure-eventhubs.partitionId* | Sets the identifier of the Event Hub partition that the events will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition. | null | false | MEDIUM
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-source-connector.adoc b/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-source-connector.adoc
index abfde7b..ce37798 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-source-connector.adoc
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/main/docs/camel-azure-eventhubs-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azureeventhubs.CamelAzureeventhu
----
-The camel-azure-eventhubs source connector supports 36 options, which are listed below.
+The camel-azure-eventhubs source connector supports 34 options, which are listed below.
@@ -35,7 +35,6 @@ The camel-azure-eventhubs source connector supports 36 options, which are listed
| *camel.source.path.eventHubName* | EventHubs name under a specific namcespace | null | false | MEDIUM
| *camel.source.endpoint.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.source.endpoint.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.blobAccessKey* | In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.source.endpoint.blobAccountName* | In case you chose the default BlobCheckpointStore, this sets Azure account name to be used for authentication with azure blob services. | null | false | MEDIUM
| *camel.source.endpoint.blobContainerName* | In case you chose the default BlobCheckpointStore, this sets the blob container that shall be used by the BlobCheckpointStore to store the checkpoint offsets | null | false | MEDIUM
@@ -52,7 +51,6 @@ The camel-azure-eventhubs source connector supports 36 options, which are listed
| *camel.source.endpoint.sharedAccessName* | The name you chose for your EventHubs SAS keys | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.component.azure-eventhubs.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-eventhubs.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-eventhubs.blobAccessKey* | In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.component.azure-eventhubs.blobAccountName* | In case you chose the default BlobCheckpointStore, this sets Azure account name to be used for authentication with azure blob services. | null | false | MEDIUM
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSinkConnectorConfig.java b/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSinkConnectorConfig.java
index 4bad182..b722fda 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSinkConnectorConfig.java
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSinkConnectorConfig.java
@@ -38,9 +38,6 @@ public class CamelAzureeventhubsSinkConnectorConfig
public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_CONF = "camel.sink.endpoint.amqpTransportType";
public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DOC = "Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets]";
public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DEFAULT = "AMQP";
- public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.sink.endpoint.autoDiscoverClient";
- public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer";
public static final String CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_DOC = "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 [...]
public static final Boolean CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -68,9 +65,6 @@ public class CamelAzureeventhubsSinkConnectorConfig
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_CONF = "camel.component.azure-eventhubs.amqpTransportType";
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DOC = "Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets]";
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DEFAULT = "AMQP";
- public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-eventhubs.autoDiscoverClient";
- public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_CONF = "camel.component.azure-eventhubs.configuration";
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DOC = "The component configurations";
public static final String CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -116,7 +110,6 @@ public class CamelAzureeventhubsSinkConnectorConfig
conf.define(CAMEL_SINK_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DOC);
- conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_ID_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_ID_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_KEY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_PARTITION_KEY_DOC);
@@ -126,7 +119,6 @@ public class CamelAzureeventhubsSinkConnectorConfig
conf.define(CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DOC);
- conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_LAZY_START_PRODUCER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_LAZY_START_PRODUCER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_PARTITION_ID_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_PARTITION_ID_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZUREEVENTHUBS_COMPONENT_PARTITION_ID_DOC);
diff --git a/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSourceConnectorConfig.java b/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSourceConnectorConfig.java
index 07e7a3c..e0890d9 100644
--- a/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSourceConnectorConfig.java
+++ b/connectors/camel-azure-eventhubs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureeventhubs/CamelAzureeventhubsSourceConnectorConfig.java
@@ -38,9 +38,6 @@ public class CamelAzureeventhubsSourceConnectorConfig
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_CONF = "camel.source.endpoint.amqpTransportType";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DOC = "Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets]";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DEFAULT = "AMQP";
- public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.source.endpoint.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_CONF = "camel.source.endpoint.blobAccessKey";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_DOC = "In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_DEFAULT = null;
@@ -89,9 +86,6 @@ public class CamelAzureeventhubsSourceConnectorConfig
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_CONF = "camel.component.azure-eventhubs.amqpTransportType";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DOC = "Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets]";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DEFAULT = "AMQP";
- public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-eventhubs.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_CONF = "camel.component.azure-eventhubs.configuration";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DOC = "The component configurations";
public static final String CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -152,7 +146,6 @@ public class CamelAzureeventhubsSourceConnectorConfig
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_PATH_EVENT_HUB_NAME_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_RETRY_OPTIONS_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AMQP_TRANSPORT_TYPE_DOC);
- conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCESS_KEY_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_ACCOUNT_NAME_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_CONTAINER_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_CONTAINER_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_BLOB_CONTAINER_NAME_DOC);
@@ -169,7 +162,6 @@ public class CamelAzureeventhubsSourceConnectorConfig
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_ENDPOINT_SHARED_ACCESS_NAME_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_RETRY_OPTIONS_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AMQP_TRANSPORT_TYPE_DOC);
- conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCESS_KEY_DOC);
conf.define(CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZUREEVENTHUBS_COMPONENT_BLOB_ACCOUNT_NAME_DOC);
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-sink.json b/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-sink.json
index c028610..fc66bfe 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-sink.json
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-sink.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.blobName": {
"name": "camel.sink.endpoint.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
@@ -222,13 +215,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-blob.autoDiscoverClient": {
- "name": "camel.component.azure-storage-blob.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-blob.blobName": {
"name": "camel.component.azure-storage-blob.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-source.json b/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-source.json
index d39070a..f849a32 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-source.json
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/generated/resources/camel-azure-storage-blob-source.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.blobName": {
"name": "camel.source.endpoint.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
@@ -274,13 +267,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-blob.autoDiscoverClient": {
- "name": "camel.component.azure-storage-blob.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-blob.blobName": {
"name": "camel.component.azure-storage-blob.blobName",
"description": "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-sink-connector.adoc b/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-sink-connector.adoc
index ba717b1..7c743cd 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-sink-connector.adoc
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestora
----
-The camel-azure-storage-blob sink connector supports 55 options, which are listed below.
+The camel-azure-storage-blob sink connector supports 53 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-blob sink connector supports 55 options, which are liste
| Name | Description | Default | Required | Priority
| *camel.sink.path.accountName* | Azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.sink.path.containerName* | The blob container name | null | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.sink.endpoint.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.sink.endpoint.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.sink.endpoint.blobServiceClient* | Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through getBlobContainerClient(String), and operations on a blob are [...]
@@ -59,7 +58,6 @@ The camel-azure-storage-blob sink connector supports 55 options, which are liste
| *camel.sink.endpoint.operation* | The blob operation that can be used with this component on the producer One of: [listBlobContainers] [createBlobContainer] [deleteBlobContainer] [listBlobs] [getBlob] [deleteBlob] [downloadBlobToFile] [downloadLink] [uploadBlockBlob] [stageBlockBlobList] [commitBlobBlockList] [getBlobBlockList] [createAppendBlob] [commitAppendBlob] [createPageBlob] [uploadPageBlob] [resizePageBlob] [clearPageBlob] [getPageBlobRanges] | "listBlobContainers" | false | MEDIUM
| *camel.sink.endpoint.pageBlobSize* | Specifies the maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a 512-byte boundary. | "512" | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
-| *camel.component.azure-storage-blob.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-blob.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.component.azure-storage-blob.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.component.azure-storage-blob.blobType* | The blob type in order to initiate the appropriate settings for each blob type One of: [blockblob] [appendblob] [pageblob] | "blockblob" | false | MEDIUM
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-source-connector.adoc b/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-source-connector.adoc
index 5d13801..dc0f020 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-source-connector.adoc
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/main/docs/camel-azure-storage-blob-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestora
----
-The camel-azure-storage-blob source connector supports 55 options, which are listed below.
+The camel-azure-storage-blob source connector supports 53 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-blob source connector supports 55 options, which are lis
| Name | Description | Default | Required | Priority
| *camel.source.path.accountName* | Azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.source.path.containerName* | The blob container name | null | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.source.endpoint.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.source.endpoint.blobServiceClient* | Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through getBlobContainerClient(String), and operations on a blob a [...]
@@ -68,7 +67,6 @@ The camel-azure-storage-blob source connector supports 55 options, which are lis
| *camel.source.endpoint.timeUnit* | Time unit for initialDelay and delay options. One of: [NANOSECONDS] [MICROSECONDS] [MILLISECONDS] [SECONDS] [MINUTES] [HOURS] [DAYS] | "MILLISECONDS" | false | MEDIUM
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.source.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
-| *camel.component.azure-storage-blob.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-blob.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.component.azure-storage-blob.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.component.azure-storage-blob.blobType* | The blob type in order to initiate the appropriate settings for each blob type One of: [blockblob] [appendblob] [pageblob] | "blockblob" | false | MEDIUM
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSinkConnectorConfig.java b/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSinkConnectorConfig.java
index ddaadc8..87bdfac 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSinkConnectorConfig.java
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSinkConnectorConfig.java
@@ -32,9 +32,6 @@ public class CamelAzurestorageblobSinkConnectorConfig
public static final String CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_CONF = "camel.sink.path.containerName";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DOC = "The blob container name";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DEFAULT = null;
- public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.sink.endpoint.autoDiscoverClient";
- public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_CONF = "camel.sink.endpoint.blobName";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DOC = "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DEFAULT = null;
@@ -110,9 +107,6 @@ public class CamelAzurestorageblobSinkConnectorConfig
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_CONF = "camel.sink.endpoint.accessKey";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DOC = "Access key for the associated azure account name to be used for authentication with azure blob services";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DEFAULT = null;
- public static final String CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-storage-blob.autoDiscoverClient";
- public static final String CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_CONF = "camel.component.azure-storage-blob.blobName";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DOC = "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level";
public static final String CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DEFAULT = null;
@@ -207,7 +201,6 @@ public class CamelAzurestorageblobSinkConnectorConfig
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DOC);
- conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_CONF, ConfigDef.Type.LONG, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_DOC);
@@ -233,7 +226,6 @@ public class CamelAzurestorageblobSinkConnectorConfig
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_OPERATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_OPERATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_OPERATION_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_PAGE_BLOB_SIZE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_PAGE_BLOB_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_PAGE_BLOB_SIZE_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DOC);
- conf.define(CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_CONF, ConfigDef.Type.LONG, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_DOC);
diff --git a/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSourceConnectorConfig.java b/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSourceConnectorConfig.java
index 5c3e73b..3a761ce 100644
--- a/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSourceConnectorConfig.java
+++ b/connectors/camel-azure-storage-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblob/CamelAzurestorageblobSourceConnectorConfig.java
@@ -32,9 +32,6 @@ public class CamelAzurestorageblobSourceConnectorConfig
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_CONF = "camel.source.path.containerName";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DOC = "The blob container name";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DEFAULT = null;
- public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.source.endpoint.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_CONF = "camel.source.endpoint.blobName";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DOC = "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DEFAULT = null;
@@ -137,9 +134,6 @@ public class CamelAzurestorageblobSourceConnectorConfig
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_CONF = "camel.source.endpoint.accessKey";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DOC = "Access key for the associated azure account name to be used for authentication with azure blob services";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DEFAULT = null;
- public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-storage-blob.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_CONF = "camel.component.azure-storage-blob.blobName";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DOC = "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level";
public static final String CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DEFAULT = null;
@@ -207,7 +201,6 @@ public class CamelAzurestorageblobSourceConnectorConfig
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_ACCOUNT_NAME_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_PATH_CONTAINER_NAME_DOC);
- conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_NAME_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_OFFSET_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_BLOB_SERVICE_CLIENT_DOC);
@@ -242,7 +235,6 @@ public class CamelAzurestorageblobSourceConnectorConfig
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_TIME_UNIT_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_TIME_UNIT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_TIME_UNIT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_USE_FIXED_DELAY_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_USE_FIXED_DELAY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_USE_FIXED_DELAY_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_ENDPOINT_ACCESS_KEY_DOC);
- conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_NAME_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_CONF, ConfigDef.Type.LONG, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_OFFSET_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEBLOB_COMPONENT_BLOB_TYPE_DOC);
diff --git a/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-sink.json b/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-sink.json
index a51fb7b..c58c9c2 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-sink.json
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-sink.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.autoDiscoverClient": {
- "name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.serviceClient": {
"name": "camel.sink.endpoint.serviceClient",
"description": "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of the account, and ret [...]
@@ -37,7 +30,7 @@
"camel.sink.endpoint.createQueue": {
"name": "camel.sink.endpoint.createQueue",
"description": "When is set to true, the queue will be automatically created when sending messages to the queue.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
@@ -114,13 +107,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-queue.autoDiscoverClient": {
- "name": "camel.component.azure-storage-queue.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-queue.configuration": {
"name": "camel.component.azure-storage-queue.configuration",
"description": "The component configurations",
@@ -136,7 +122,7 @@
"camel.component.azure-storage-queue.createQueue": {
"name": "camel.component.azure-storage-queue.createQueue",
"description": "When is set to true, the queue will be automatically created when sending messages to the queue.",
- "defaultValue": "true",
+ "defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
},
diff --git a/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-source.json b/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-source.json
index 1527b3c..7c4571b 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-source.json
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/generated/resources/camel-azure-storage-queue-source.json
@@ -21,13 +21,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.autoDiscoverClient": {
- "name": "camel.source.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.source.endpoint.serviceClient": {
"name": "camel.source.endpoint.serviceClient",
"description": "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of the account, and ret [...]
@@ -230,13 +223,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.azure-storage-queue.autoDiscoverClient": {
- "name": "camel.component.azure-storage-queue.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
- "defaultValue": "true",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.azure-storage-queue.configuration": {
"name": "camel.component.azure-storage-queue.configuration",
"description": "The component configurations",
diff --git a/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-sink-connector.adoc b/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-sink-connector.adoc
index 2b7bad1..42e0124 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-sink-connector.adoc
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestoragequeue.CamelAzurestor
----
-The camel-azure-storage-queue sink connector supports 30 options, which are listed below.
+The camel-azure-storage-queue sink connector supports 28 options, which are listed below.
@@ -33,9 +33,8 @@ The camel-azure-storage-queue sink connector supports 30 options, which are list
| Name | Description | Default | Required | Priority
| *camel.sink.path.accountName* | Azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.sink.path.queueName* | The queue resource name | null | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.sink.endpoint.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of [...]
-| *camel.sink.endpoint.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | true | false | MEDIUM
+| *camel.sink.endpoint.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | false | 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 [...]
| *camel.sink.endpoint.operation* | Queue service operation hint to the producer One of: [listQueues] [createQueue] [deleteQueue] [clearQueue] [sendMessage] [deleteMessage] [receiveMessages] [peekMessages] [updateMessage] | null | false | MEDIUM
| *camel.sink.endpoint.maxMessages* | Maximum number of messages to get, if there are less messages exist in the queue than requested all the messages will be returned. If left empty only 1 message will be retrieved, the allowed range is 1 to 32 messages. | "1" | false | MEDIUM
@@ -46,10 +45,9 @@ The camel-azure-storage-queue sink connector supports 30 options, which are list
| *camel.sink.endpoint.visibilityTimeout* | The timeout period for how long the message is invisible in the queue. The timeout must be between 1 seconds and 7 days. The format should be in this form: PnDTnHnMn.nS., e.g: PT20.345S -- parses as 20.345 seconds, P2D -- parses as 2 days However, in case you are using EndpointDsl/ComponentDsl, you can do something like Duration.ofSeconds() since these Java APIs are typesafe. | null | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.sink.endpoint.credentials* | StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information | null | false | MEDIUM
-| *camel.component.azure-storage-queue.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-queue.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-storage-queue.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updati [...]
-| *camel.component.azure-storage-queue.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | true | false | MEDIUM
+| *camel.component.azure-storage-queue.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | false | false | MEDIUM
| *camel.component.azure-storage-queue.lazyStart Producer* | 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 p [...]
| *camel.component.azure-storage-queue.operation* | Queue service operation hint to the producer One of: [listQueues] [createQueue] [deleteQueue] [clearQueue] [sendMessage] [deleteMessage] [receiveMessages] [peekMessages] [updateMessage] | null | false | MEDIUM
| *camel.component.azure-storage-queue.autowired Enabled* | 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-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-source-connector.adoc b/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-source-connector.adoc
index cd53796..194154c 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-source-connector.adoc
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/main/docs/camel-azure-storage-queue-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestoragequeue.CamelAzurestor
----
-The camel-azure-storage-queue source connector supports 44 options, which are listed below.
+The camel-azure-storage-queue source connector supports 42 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-queue source connector supports 44 options, which are li
| Name | Description | Default | Required | Priority
| *camel.source.path.accountName* | Azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.source.path.queueName* | The queue resource name | null | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties [...]
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
| *camel.source.endpoint.sendEmptyMessageWhenIdle* | If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead. | false | false | MEDIUM
@@ -62,7 +61,6 @@ The camel-azure-storage-queue source connector supports 44 options, which are li
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.source.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.source.endpoint.credentials* | StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information | null | false | MEDIUM
-| *camel.component.azure-storage-queue.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-queue.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-storage-queue.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updati [...]
| *camel.component.azure-storage-queue.bridgeError Handler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
diff --git a/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSinkConnectorConfig.java b/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSinkConnectorConfig.java
index e3042de..1453ed2 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSinkConnectorConfig.java
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSinkConnectorConfig.java
@@ -32,15 +32,12 @@ public class CamelAzurestoragequeueSinkConnectorConfig
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_CONF = "camel.sink.path.queueName";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DOC = "The queue resource name";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DEFAULT = null;
- public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.sink.endpoint.autoDiscoverClient";
- public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_CONF = "camel.sink.endpoint.serviceClient";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DOC = "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and del [...]
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_CONF = "camel.sink.endpoint.createQueue";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_DOC = "When is set to true, the queue will be automatically created when sending messages to the queue.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_DOC = "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. Bewa [...]
public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -71,9 +68,6 @@ public class CamelAzurestoragequeueSinkConnectorConfig
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_CONF = "camel.sink.endpoint.credentials";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DOC = "StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DEFAULT = null;
- public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-storage-queue.autoDiscoverClient";
- public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_CONF = "camel.component.azure-storage-queue.configuration";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DOC = "The component configurations";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -82,7 +76,7 @@ public class CamelAzurestoragequeueSinkConnectorConfig
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_DEFAULT = null;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_CONF = "camel.component.azure-storage-queue.createQueue";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_DOC = "When is set to true, the queue will be automatically created when sending messages to the queue.";
- public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_DEFAULT = true;
+ public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_DEFAULT = false;
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_LAZY_START_PRODUCER_CONF = "camel.component.azure-storage-queue.lazyStartProducer";
public static final String CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_LAZY_START_PRODUCER_DOC = "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. Bew [...]
public static final Boolean CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -132,7 +126,6 @@ public class CamelAzurestoragequeueSinkConnectorConfig
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DOC);
- conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREATE_QUEUE_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_LAZY_START_PRODUCER_DOC);
@@ -145,7 +138,6 @@ public class CamelAzurestoragequeueSinkConnectorConfig
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_VISIBILITY_TIMEOUT_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_VISIBILITY_TIMEOUT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_VISIBILITY_TIMEOUT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DOC);
- conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_DOC);
conf.define(CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AZURESTORAGEQUEUE_COMPONENT_CREATE_QUEUE_DOC);
diff --git a/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSourceConnectorConfig.java b/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSourceConnectorConfig.java
index dddc8a6..90594c3 100644
--- a/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSourceConnectorConfig.java
+++ b/connectors/camel-azure-storage-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragequeue/CamelAzurestoragequeueSourceConnectorConfig.java
@@ -32,9 +32,6 @@ public class CamelAzurestoragequeueSourceConnectorConfig
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_CONF = "camel.source.path.queueName";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DOC = "The queue resource name";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DEFAULT = null;
- public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF = "camel.source.endpoint.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_CONF = "camel.source.endpoint.serviceClient";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DOC = "Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and d [...]
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DEFAULT = null;
@@ -119,9 +116,6 @@ public class CamelAzurestoragequeueSourceConnectorConfig
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_CONF = "camel.source.endpoint.credentials";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DOC = "StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DEFAULT = null;
- public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF = "camel.component.azure-storage-queue.autoDiscoverClient";
- public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.";
- public static final Boolean CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_CONF = "camel.component.azure-storage-queue.configuration";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DOC = "The component configurations";
public static final String CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -174,7 +168,6 @@ public class CamelAzurestoragequeueSourceConnectorConfig
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_ACCOUNT_NAME_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_PATH_QUEUE_NAME_DOC);
- conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SERVICE_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_SEND_EMPTY_MESSAGE_WHEN_IDLE_DOC);
@@ -203,7 +196,6 @@ public class CamelAzurestoragequeueSourceConnectorConfig
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_USE_FIXED_DELAY_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_USE_FIXED_DELAY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_USE_FIXED_DELAY_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_ENDPOINT_CREDENTIALS_DOC);
- conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_SERVICE_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_BRIDGE_ERROR_HANDLER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AZURESTORAGEQUEUE_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
diff --git a/connectors/camel-github-kafka-connector/src/generated/resources/camel-github-source.json b/connectors/camel-github-kafka-connector/src/generated/resources/camel-github-source.json
index 3447dfd..0c35219 100644
--- a/connectors/camel-github-kafka-connector/src/generated/resources/camel-github-source.json
+++ b/connectors/camel-github-kafka-connector/src/generated/resources/camel-github-source.json
@@ -33,6 +33,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.path.startingSha": {
+ "name": "camel.source.path.startingSha",
+ "description": "The starting sha to use for polling commits with the commit consumer. The value can either be a sha for the sha to start from, or use beginning to start from the beginning, or last to start from the last commit.",
+ "defaultValue": "\"last\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.repoName": {
"name": "camel.source.endpoint.repoName",
"description": "GitHub repository name",
diff --git a/connectors/camel-github-kafka-connector/src/main/docs/camel-github-kafka-source-connector.adoc b/connectors/camel-github-kafka-connector/src/main/docs/camel-github-kafka-source-connector.adoc
index d2144a0..a3276ac 100644
--- a/connectors/camel-github-kafka-connector/src/main/docs/camel-github-kafka-source-connector.adoc
+++ b/connectors/camel-github-kafka-connector/src/main/docs/camel-github-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.github.CamelGithubSourceConnecto
----
-The camel-github source connector supports 28 options, which are listed below.
+The camel-github source connector supports 29 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-github source connector supports 28 options, which are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.type* | What git operation to execute One of: [CLOSEPULLREQUEST] [PULLREQUESTCOMMENT] [COMMIT] [PULLREQUEST] [TAG] [PULLREQUESTSTATE] [PULLREQUESTFILES] [GETCOMMITFILE] [CREATEISSUE] [EVENT] | null | true | HIGH
| *camel.source.path.branchName* | Name of branch | null | false | MEDIUM
+| *camel.source.path.startingSha* | The starting sha to use for polling commits with the commit consumer. The value can either be a sha for the sha to start from, or use beginning to start from the beginning, or last to start from the last commit. | "last" | false | MEDIUM
| *camel.source.endpoint.repoName* | GitHub repository name | null | true | HIGH
| *camel.source.endpoint.repoOwner* | GitHub repository owner (organization) | null | true | HIGH
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
diff --git a/connectors/camel-github-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/github/CamelGithubSourceConnectorConfig.java b/connectors/camel-github-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/github/CamelGithubSourceConnectorConfig.java
index e3e20a1..c705182 100644
--- a/connectors/camel-github-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/github/CamelGithubSourceConnectorConfig.java
+++ b/connectors/camel-github-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/github/CamelGithubSourceConnectorConfig.java
@@ -32,6 +32,9 @@ public class CamelGithubSourceConnectorConfig
public static final String CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_CONF = "camel.source.path.branchName";
public static final String CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_DOC = "Name of branch";
public static final String CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_DEFAULT = null;
+ public static final String CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_CONF = "camel.source.path.startingSha";
+ public static final String CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_DOC = "The starting sha to use for polling commits with the commit consumer. The value can either be a sha for the sha to start from, or use beginning to start from the beginning, or last to start from the last commit.";
+ public static final String CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_DEFAULT = "last";
public static final String CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_CONF = "camel.source.endpoint.repoName";
public static final String CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_DOC = "GitHub repository name";
public static final String CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_DEFAULT = null;
@@ -125,6 +128,7 @@ public class CamelGithubSourceConnectorConfig
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_GITHUB_PATH_TYPE_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_GITHUB_PATH_TYPE_DEFAULT, ConfigDef.Importance.HIGH, CAMEL_SOURCE_GITHUB_PATH_TYPE_DOC);
conf.define(CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_GITHUB_PATH_BRANCH_NAME_DOC);
+ conf.define(CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_GITHUB_PATH_STARTING_SHA_DOC);
conf.define(CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_DEFAULT, ConfigDef.Importance.HIGH, CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_NAME_DOC);
conf.define(CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_OWNER_CONF, ConfigDef.Type.STRING, CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_OWNER_DEFAULT, ConfigDef.Importance.HIGH, CAMEL_SOURCE_GITHUB_ENDPOINT_REPO_OWNER_DOC);
conf.define(CAMEL_SOURCE_GITHUB_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_GITHUB_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_GITHUB_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
diff --git a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
index 5e5aa7c..ffdee48 100644
--- a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
+++ b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
@@ -6,7 +6,7 @@
"id": "camel-kamelet-sink",
"type": "sink",
"version": "0.10.0-SNAPSHOT",
- "description": "The Kamelet Component provides support for interacting with the Camel Route Template engine"
+ "description": "To call Kamelets"
},
"properties": {
"camel.sink.path.templateId": {
diff --git a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
index 57eed6b..4322644 100644
--- a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
+++ b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
@@ -6,7 +6,7 @@
"id": "camel-kamelet-source",
"type": "source",
"version": "0.10.0-SNAPSHOT",
- "description": "The Kamelet Component provides support for interacting with the Camel Route Template engine"
+ "description": "To call Kamelets"
},
"properties": {
"camel.source.path.templateId": {
diff --git a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
index 2d5fcb0..3e8a764 100644
--- a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
+++ b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-kamelet-kafka-connector-sink]]
= camel-kamelet-kafka-connector sink configuration
-Connector Description: The Kamelet Component provides support for interacting with the Camel Route Template engine
+Connector Description: To call Kamelets
When using camel-kamelet-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
diff --git a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
index f76e5d5..06ea14f 100644
--- a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
+++ b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
@@ -2,7 +2,7 @@
[[camel-kamelet-kafka-connector-source]]
= camel-kamelet-kafka-connector source configuration
-Connector description: The Kamelet Component provides support for interacting with the Camel Route Template engine
+Connector description: To call Kamelets
When using camel-kamelet-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
diff --git a/connectors/camel-vertx-http-kafka-connector/src/generated/resources/camel-vertx-http-sink.json b/connectors/camel-vertx-http-kafka-connector/src/generated/resources/camel-vertx-http-sink.json
index 5a6f04a..0a7947c 100644
--- a/connectors/camel-vertx-http-kafka-connector/src/generated/resources/camel-vertx-http-sink.json
+++ b/connectors/camel-vertx-http-kafka-connector/src/generated/resources/camel-vertx-http-sink.json
@@ -38,21 +38,9 @@
},
"camel.sink.endpoint.httpMethod": {
"name": "camel.sink.endpoint.httpMethod",
- "description": "The HTTP method to use. The HttpMethod header cannot override this option if set One of: [OPTIONS] [GET] [HEAD] [POST] [PUT] [DELETE] [TRACE] [CONNECT] [PATCH] [OTHER]",
+ "description": "The HTTP method to use. The HttpMethod header cannot override this option if set",
"priority": "MEDIUM",
- "required": "false",
- "enum": [
- "OPTIONS",
- "GET",
- "HEAD",
- "POST",
- "PUT",
- "DELETE",
- "TRACE",
- "CONNECT",
- "PATCH",
- "OTHER"
- ]
+ "required": "false"
},
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
diff --git a/connectors/camel-vertx-http-kafka-connector/src/main/docs/camel-vertx-http-kafka-sink-connector.adoc b/connectors/camel-vertx-http-kafka-connector/src/main/docs/camel-vertx-http-kafka-sink-connector.adoc
index 84077cd..6ee9c75 100644
--- a/connectors/camel-vertx-http-kafka-connector/src/main/docs/camel-vertx-http-kafka-sink-connector.adoc
+++ b/connectors/camel-vertx-http-kafka-connector/src/main/docs/camel-vertx-http-kafka-sink-connector.adoc
@@ -35,7 +35,7 @@ The camel-vertx-http sink connector supports 42 options, which are listed below.
| *camel.sink.endpoint.connectTimeout* | The amount of time in milliseconds until a connection is established. A timeout value of zero is interpreted as an infinite timeout. | 60000 | false | MEDIUM
| *camel.sink.endpoint.cookieStore* | A custom CookieStore to use when session management is enabled. If this option is not set then an in-memory CookieStore is used | "InMemoryCookieStore" | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | A custom org.apache.camel.spi.HeaderFilterStrategy to filter header to and from Camel message. | "VertxHttpHeaderFilterStrategy" | false | MEDIUM
-| *camel.sink.endpoint.httpMethod* | The HTTP method to use. The HttpMethod header cannot override this option if set One of: [OPTIONS] [GET] [HEAD] [POST] [PUT] [DELETE] [TRACE] [CONNECT] [PATCH] [OTHER] | null | false | MEDIUM
+| *camel.sink.endpoint.httpMethod* | The HTTP method to use. The HttpMethod header cannot override this option if set | 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 [...]
| *camel.sink.endpoint.okStatusCodeRange* | The status codes which are considered a success response. The values are inclusive. Multiple ranges can be defined, separated by comma, e.g. 200-204,209,301-304. Each range must be a single number or from-to with the dash included | "200-299" | false | MEDIUM
| *camel.sink.endpoint.responsePayloadAsByteArray* | Whether the response body should be byte or as io.vertx.core.buffer.Buffer | true | false | MEDIUM
diff --git a/connectors/camel-vertx-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxhttp/CamelVertxhttpSinkConnectorConfig.java b/connectors/camel-vertx-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxhttp/CamelVertxhttpSinkConnectorConfig.java
index 3b0642b..9159cd9 100644
--- a/connectors/camel-vertx-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxhttp/CamelVertxhttpSinkConnectorConfig.java
+++ b/connectors/camel-vertx-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/vertxhttp/CamelVertxhttpSinkConnectorConfig.java
@@ -39,7 +39,7 @@ public class CamelVertxhttpSinkConnectorConfig
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HEADER_FILTER_STRATEGY_DOC = "A custom org.apache.camel.spi.HeaderFilterStrategy to filter header to and from Camel message.";
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HEADER_FILTER_STRATEGY_DEFAULT = "VertxHttpHeaderFilterStrategy";
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HTTP_METHOD_CONF = "camel.sink.endpoint.httpMethod";
- public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HTTP_METHOD_DOC = "The HTTP method to use. The HttpMethod header cannot override this option if set One of: [OPTIONS] [GET] [HEAD] [POST] [PUT] [DELETE] [TRACE] [CONNECT] [PATCH] [OTHER]";
+ public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HTTP_METHOD_DOC = "The HTTP method to use. The HttpMethod header cannot override this option if set";
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_HTTP_METHOD_DEFAULT = null;
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_LAZY_START_PRODUCER_CONF = "camel.sink.endpoint.lazyStartProducer";
public static final String CAMEL_SINK_VERTXHTTP_ENDPOINT_LAZY_START_PRODUCER_DOC = "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 [...]
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index a1a2468..fa50377 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -190,8 +190,6 @@
*** xref:connectors/camel-cql-kafka-sink-connector.adoc[Sink Docs]
** camel-cron-kafka-connector
*** xref:connectors/camel-cron-kafka-source-connector.adoc[Source Docs]
-** camel-crypto-cms-kafka-connector
-*** xref:connectors/camel-crypto-cms-kafka-sink-connector.adoc[Sink Docs]
** camel-crypto-kafka-connector
*** xref:connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs]
** camel-cxf-kafka-connector
diff --git a/docs/modules/ROOT/pages/connectors.adoc b/docs/modules/ROOT/pages/connectors.adoc
index b3a343d..98164ea 100644
--- a/docs/modules/ROOT/pages/connectors.adoc
+++ b/docs/modules/ROOT/pages/connectors.adoc
@@ -2,7 +2,7 @@
= Supported connectors and documentation
// kafka-connectors list: START
-Number of Camel Kafka connectors: 337
+Number of Camel Kafka connectors: 336
[width="100%",cols="4,1,1,1,1,1",options="header"]
|===
@@ -76,7 +76,6 @@ Number of Camel Kafka connectors: 337
| *camel-couchdb-kafka-connector* | true | true | xref:connectors/camel-couchdb-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-couchdb-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-couchdb-kafka-connector/0.9.0/camel-couchdb-kafka-connector-0.9.0-package.tar.gz[Download]
| *camel-cql-kafka-connector* | true | true | xref:connectors/camel-cql-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cql-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.9.0/camel-cql-kafka-connector-0.9.0-package.tar.gz[Download]
| *camel-cron-kafka-connector* | false | true | | xref:connectors/camel-cron-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cron-kafka-connector/0.9.0/camel-cron-kafka-connector-0.9.0-package.tar.gz[Download]
-| *camel-crypto-cms-kafka-connector* | true | false | xref:connectors/camel-crypto-cms-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-crypto-cms-kafka-connector/0.9.0/camel-crypto-cms-kafka-connector-0.9.0-package.tar.gz[Download]
| *camel-crypto-kafka-connector* | true | false | xref:connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-crypto-kafka-connector/0.9.0/camel-crypto-kafka-connector-0.9.0-package.tar.gz[Download]
| *camel-cxf-kafka-connector* | true | true | xref:connectors/camel-cxf-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cxf-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cxf-kafka-connector/0.9.0/camel-cxf-kafka-connector-0.9.0-package.tar.gz[Download]
| *camel-cxfrs-kafka-connector* | true | true | xref:connectors/camel-cxfrs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cxfrs-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cxfrs-kafka-connector/0.9.0/camel-cxfrs-kafka-connector-0.9.0-package.tar.gz[Download]
diff --git a/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc
index 03e6012..ee436a1 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azureeventhubs.CamelAzureeventhu
----
-The camel-azure-eventhubs sink connector supports 24 options, which are listed below.
+The camel-azure-eventhubs sink connector supports 22 options, which are listed below.
@@ -35,7 +35,6 @@ The camel-azure-eventhubs sink connector supports 24 options, which are listed b
| *camel.sink.path.eventHubName* | EventHubs name under a specific namcespace | null | false | MEDIUM
| *camel.sink.endpoint.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.sink.endpoint.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | 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 [...]
| *camel.sink.endpoint.partitionId* | Sets the identifier of the Event Hub partition that the events will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition. | null | false | MEDIUM
| *camel.sink.endpoint.partitionKey* | Sets a hashing key to be provided for the batch of events, which instructs the Event Hubs service to map this key to a specific partition. The selection of a partition is stable for a given partition hashing key. Should any other batches of events be sent using the same exact partition hashing key, the Event Hubs service will route them all to the same partition. This should be specified only when there is a need to group events by partition, but th [...]
@@ -45,7 +44,6 @@ The camel-azure-eventhubs sink connector supports 24 options, which are listed b
| *camel.sink.endpoint.sharedAccessName* | The name you chose for your EventHubs SAS keys | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.component.azure-eventhubs.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-eventhubs.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-eventhubs.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 proces [...]
| *camel.component.azure-eventhubs.partitionId* | Sets the identifier of the Event Hub partition that the events will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-source-connector.adoc
index abfde7b..ce37798 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-eventhubs-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azureeventhubs.CamelAzureeventhu
----
-The camel-azure-eventhubs source connector supports 36 options, which are listed below.
+The camel-azure-eventhubs source connector supports 34 options, which are listed below.
@@ -35,7 +35,6 @@ The camel-azure-eventhubs source connector supports 36 options, which are listed
| *camel.source.path.eventHubName* | EventHubs name under a specific namcespace | null | false | MEDIUM
| *camel.source.endpoint.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.source.endpoint.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.blobAccessKey* | In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.source.endpoint.blobAccountName* | In case you chose the default BlobCheckpointStore, this sets Azure account name to be used for authentication with azure blob services. | null | false | MEDIUM
| *camel.source.endpoint.blobContainerName* | In case you chose the default BlobCheckpointStore, this sets the blob container that shall be used by the BlobCheckpointStore to store the checkpoint offsets | null | false | MEDIUM
@@ -52,7 +51,6 @@ The camel-azure-eventhubs source connector supports 36 options, which are listed
| *camel.source.endpoint.sharedAccessName* | The name you chose for your EventHubs SAS keys | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpRetryOptions* | Sets the retry policy for EventHubAsyncClient. If not specified, the default retry options are used. | null | false | MEDIUM
| *camel.component.azure-eventhubs.amqpTransportType* | Sets the transport type by which all the communication with Azure Event Hubs occurs. Default value is AmqpTransportType#AMQP. One of: [Amqp] [AmqpWebSockets] | "AMQP" | false | MEDIUM
-| *camel.component.azure-eventhubs.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-eventhubs.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-eventhubs.blobAccessKey* | In case you chose the default BlobCheckpointStore, this sets access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.component.azure-eventhubs.blobAccountName* | In case you chose the default BlobCheckpointStore, this sets Azure account name to be used for authentication with azure blob services. | null | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc
index ba717b1..7c743cd 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestora
----
-The camel-azure-storage-blob sink connector supports 55 options, which are listed below.
+The camel-azure-storage-blob sink connector supports 53 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-blob sink connector supports 55 options, which are liste
| Name | Description | Default | Required | Priority
| *camel.sink.path.accountName* | Azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.sink.path.containerName* | The blob container name | null | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.sink.endpoint.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.sink.endpoint.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.sink.endpoint.blobServiceClient* | Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through getBlobContainerClient(String), and operations on a blob are [...]
@@ -59,7 +58,6 @@ The camel-azure-storage-blob sink connector supports 55 options, which are liste
| *camel.sink.endpoint.operation* | The blob operation that can be used with this component on the producer One of: [listBlobContainers] [createBlobContainer] [deleteBlobContainer] [listBlobs] [getBlob] [deleteBlob] [downloadBlobToFile] [downloadLink] [uploadBlockBlob] [stageBlockBlobList] [commitBlobBlockList] [getBlobBlockList] [createAppendBlob] [commitAppendBlob] [createPageBlob] [uploadPageBlob] [resizePageBlob] [clearPageBlob] [getPageBlobRanges] | "listBlobContainers" | false | MEDIUM
| *camel.sink.endpoint.pageBlobSize* | Specifies the maximum size for the page blob, up to 8 TB. The page blob size must be aligned to a 512-byte boundary. | "512" | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
-| *camel.component.azure-storage-blob.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-blob.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.component.azure-storage-blob.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.component.azure-storage-blob.blobType* | The blob type in order to initiate the appropriate settings for each blob type One of: [blockblob] [appendblob] [pageblob] | "blockblob" | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-source-connector.adoc
index 5d13801..dc0f020 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-storage-blob-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestora
----
-The camel-azure-storage-blob source connector supports 55 options, which are listed below.
+The camel-azure-storage-blob source connector supports 53 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-blob source connector supports 55 options, which are lis
| Name | Description | Default | Required | Priority
| *camel.source.path.accountName* | Azure account name to be used for authentication with azure blob services | null | false | MEDIUM
| *camel.source.path.containerName* | The blob container name | null | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.source.endpoint.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.source.endpoint.blobServiceClient* | Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through getBlobContainerClient(String), and operations on a blob a [...]
@@ -68,7 +67,6 @@ The camel-azure-storage-blob source connector supports 55 options, which are lis
| *camel.source.endpoint.timeUnit* | Time unit for initialDelay and delay options. One of: [NANOSECONDS] [MICROSECONDS] [MILLISECONDS] [SECONDS] [MINUTES] [HOURS] [DAYS] | "MILLISECONDS" | false | MEDIUM
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.source.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure blob services | null | false | MEDIUM
-| *camel.component.azure-storage-blob.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-blob.blobName* | The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level | null | false | MEDIUM
| *camel.component.azure-storage-blob.blobOffset* | Set the blob offset for the upload or download operations, default is 0 | 0L | false | MEDIUM
| *camel.component.azure-storage-blob.blobType* | The blob type in order to initiate the appropriate settings for each blob type One of: [blockblob] [appendblob] [pageblob] | "blockblob" | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-sink-connector.adoc
index 2b7bad1..42e0124 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestoragequeue.CamelAzurestor
----
-The camel-azure-storage-queue sink connector supports 30 options, which are listed below.
+The camel-azure-storage-queue sink connector supports 28 options, which are listed below.
@@ -33,9 +33,8 @@ The camel-azure-storage-queue sink connector supports 30 options, which are list
| Name | Description | Default | Required | Priority
| *camel.sink.path.accountName* | Azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.sink.path.queueName* | The queue resource name | null | false | MEDIUM
-| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.sink.endpoint.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties of [...]
-| *camel.sink.endpoint.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | true | false | MEDIUM
+| *camel.sink.endpoint.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | false | 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 [...]
| *camel.sink.endpoint.operation* | Queue service operation hint to the producer One of: [listQueues] [createQueue] [deleteQueue] [clearQueue] [sendMessage] [deleteMessage] [receiveMessages] [peekMessages] [updateMessage] | null | false | MEDIUM
| *camel.sink.endpoint.maxMessages* | Maximum number of messages to get, if there are less messages exist in the queue than requested all the messages will be returned. If left empty only 1 message will be retrieved, the allowed range is 1 to 32 messages. | "1" | false | MEDIUM
@@ -46,10 +45,9 @@ The camel-azure-storage-queue sink connector supports 30 options, which are list
| *camel.sink.endpoint.visibilityTimeout* | The timeout period for how long the message is invisible in the queue. The timeout must be between 1 seconds and 7 days. The format should be in this form: PnDTnHnMn.nS., e.g: PT20.345S -- parses as 20.345 seconds, P2D -- parses as 2 days However, in case you are using EndpointDsl/ComponentDsl, you can do something like Duration.ofSeconds() since these Java APIs are typesafe. | null | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.sink.endpoint.credentials* | StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information | null | false | MEDIUM
-| *camel.component.azure-storage-queue.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-queue.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-storage-queue.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updati [...]
-| *camel.component.azure-storage-queue.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | true | false | MEDIUM
+| *camel.component.azure-storage-queue.createQueue* | When is set to true, the queue will be automatically created when sending messages to the queue. | false | false | MEDIUM
| *camel.component.azure-storage-queue.lazyStart Producer* | 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 p [...]
| *camel.component.azure-storage-queue.operation* | Queue service operation hint to the producer One of: [listQueues] [createQueue] [deleteQueue] [clearQueue] [sendMessage] [deleteMessage] [receiveMessages] [peekMessages] [updateMessage] | null | false | MEDIUM
| *camel.component.azure-storage-queue.autowired Enabled* | 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/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-source-connector.adoc
index cd53796..194154c 100644
--- a/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-azure-storage-queue-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.azurestoragequeue.CamelAzurestor
----
-The camel-azure-storage-queue source connector supports 44 options, which are listed below.
+The camel-azure-storage-queue source connector supports 42 options, which are listed below.
@@ -33,7 +33,6 @@ The camel-azure-storage-queue source connector supports 44 options, which are li
| Name | Description | Default | Required | Priority
| *camel.source.path.accountName* | Azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.source.path.queueName* | The queue resource name | null | false | MEDIUM
-| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.source.endpoint.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updating properties [...]
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
| *camel.source.endpoint.sendEmptyMessageWhenIdle* | If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead. | false | false | MEDIUM
@@ -62,7 +61,6 @@ The camel-azure-storage-queue source connector supports 44 options, which are li
| *camel.source.endpoint.useFixedDelay* | Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details. | true | false | MEDIUM
| *camel.source.endpoint.accessKey* | Access key for the associated azure account name to be used for authentication with azure queue services | null | false | MEDIUM
| *camel.source.endpoint.credentials* | StorageSharedKeyCredential can be injected to create the azure client, this holds the important authentication information | null | false | MEDIUM
-| *camel.component.azure-storage-queue.autoDiscover Client* | Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. | true | false | MEDIUM
| *camel.component.azure-storage-queue.configuration* | The component configurations | null | false | MEDIUM
| *camel.component.azure-storage-queue.serviceClient* | Service client to a storage account to interact with the queue service. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. This client contains all the operations for interacting with a queue account in Azure Storage. Operations allowed by the client are creating, listing, and deleting queues, retrieving and updati [...]
| *camel.component.azure-storage-queue.bridgeError Handler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-github-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-github-kafka-source-connector.adoc
index d2144a0..a3276ac 100644
--- a/docs/modules/ROOT/pages/connectors/camel-github-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-github-kafka-source-connector.adoc
@@ -24,7 +24,7 @@ connector.class=org.apache.camel.kafkaconnector.github.CamelGithubSourceConnecto
----
-The camel-github source connector supports 28 options, which are listed below.
+The camel-github source connector supports 29 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-github source connector supports 28 options, which are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.type* | What git operation to execute One of: [CLOSEPULLREQUEST] [PULLREQUESTCOMMENT] [COMMIT] [PULLREQUEST] [TAG] [PULLREQUESTSTATE] [PULLREQUESTFILES] [GETCOMMITFILE] [CREATEISSUE] [EVENT] | null | true | HIGH
| *camel.source.path.branchName* | Name of branch | null | false | MEDIUM
+| *camel.source.path.startingSha* | The starting sha to use for polling commits with the commit consumer. The value can either be a sha for the sha to start from, or use beginning to start from the beginning, or last to start from the last commit. | "last" | false | MEDIUM
| *camel.source.endpoint.repoName* | GitHub repository name | null | true | HIGH
| *camel.source.endpoint.repoOwner* | GitHub repository owner (organization) | null | true | HIGH
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | false | MEDIUM
diff --git a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
index 2d5fcb0..3e8a764 100644
--- a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-kamelet-kafka-connector-sink]]
= camel-kamelet-kafka-connector sink configuration
-Connector Description: The Kamelet Component provides support for interacting with the Camel Route Template engine
+Connector Description: To call Kamelets
When using camel-kamelet-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
diff --git a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
index f76e5d5..06ea14f 100644
--- a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
@@ -2,7 +2,7 @@
[[camel-kamelet-kafka-connector-source]]
= camel-kamelet-kafka-connector source configuration
-Connector description: The Kamelet Component provides support for interacting with the Camel Route Template engine
+Connector description: To call Kamelets
When using camel-kamelet-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
diff --git a/docs/modules/ROOT/pages/connectors/camel-vertx-http-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-vertx-http-kafka-sink-connector.adoc
index 84077cd..6ee9c75 100644
--- a/docs/modules/ROOT/pages/connectors/camel-vertx-http-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-vertx-http-kafka-sink-connector.adoc
@@ -35,7 +35,7 @@ The camel-vertx-http sink connector supports 42 options, which are listed below.
| *camel.sink.endpoint.connectTimeout* | The amount of time in milliseconds until a connection is established. A timeout value of zero is interpreted as an infinite timeout. | 60000 | false | MEDIUM
| *camel.sink.endpoint.cookieStore* | A custom CookieStore to use when session management is enabled. If this option is not set then an in-memory CookieStore is used | "InMemoryCookieStore" | false | MEDIUM
| *camel.sink.endpoint.headerFilterStrategy* | A custom org.apache.camel.spi.HeaderFilterStrategy to filter header to and from Camel message. | "VertxHttpHeaderFilterStrategy" | false | MEDIUM
-| *camel.sink.endpoint.httpMethod* | The HTTP method to use. The HttpMethod header cannot override this option if set One of: [OPTIONS] [GET] [HEAD] [POST] [PUT] [DELETE] [TRACE] [CONNECT] [PATCH] [OTHER] | null | false | MEDIUM
+| *camel.sink.endpoint.httpMethod* | The HTTP method to use. The HttpMethod header cannot override this option if set | 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 [...]
| *camel.sink.endpoint.okStatusCodeRange* | The status codes which are considered a success response. The values are inclusive. Multiple ranges can be defined, separated by comma, e.g. 200-204,209,301-304. Each range must be a single number or from-to with the dash included | "200-299" | false | MEDIUM
| *camel.sink.endpoint.responsePayloadAsByteArray* | Whether the response body should be byte or as io.vertx.core.buffer.Buffer | true | false | MEDIUM