This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/camel-master by this push:
new a6b1bac [create-pull-request] automated change
a6b1bac is described below
commit a6b1bacce2c237661e6e7de516fdea4d2ce8a6e7
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Mar 6 03:28:51 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-aws2-sts-sink.json | 26 ++++++++++++++++++++++
.../connectors/camel-aws2-translate-sink.json | 26 ++++++++++++++++++++++
.../connectors/camel-google-bigquery-sql-sink.json | 12 +++++-----
.../connectors/camel-google-pubsub-sink.json | 14 ++++++++----
.../connectors/camel-google-pubsub-source.json | 14 ++++++++----
.../connectors/camel-spring-rabbitmq-source.json | 6 +++++
.../generated/resources/camel-aws2-sts-sink.json | 26 ++++++++++++++++++++++
.../docs/camel-aws2-sts-kafka-sink-connector.adoc | 6 ++++-
.../aws2sts/CamelAws2stsSinkConnectorConfig.java | 16 +++++++++++++
.../resources/camel-aws2-translate-sink.json | 26 ++++++++++++++++++++++
.../camel-aws2-translate-kafka-sink-connector.adoc | 6 ++++-
.../CamelAws2translateSinkConnectorConfig.java | 16 +++++++++++++
.../resources/camel-google-bigquery-sql-sink.json | 12 +++++-----
...l-google-bigquery-sql-kafka-sink-connector.adoc | 2 +-
.../CamelGooglebigquerysqlSinkConnector.properties | 2 +-
.../CamelGooglebigquerysqlSinkConnectorConfig.java | 8 +++----
.../resources/camel-google-pubsub-sink.json | 14 ++++++++----
.../resources/camel-google-pubsub-source.json | 14 ++++++++----
.../camel-google-pubsub-kafka-sink-connector.adoc | 9 ++++----
...camel-google-pubsub-kafka-source-connector.adoc | 9 ++++----
.../CamelGooglepubsubSinkConnector.properties | 8 +++++--
.../CamelGooglepubsubSourceConnector.properties | 8 +++++--
.../CamelGooglepubsubSinkConnectorConfig.java | 10 ++++++---
.../CamelGooglepubsubSourceConnectorConfig.java | 10 ++++++---
.../resources/camel-spring-rabbitmq-source.json | 6 +++++
...mel-spring-rabbitmq-kafka-source-connector.adoc | 3 ++-
.../CamelSpringrabbitmqSourceConnectorConfig.java | 4 ++++
.../camel-aws2-sts-kafka-sink-connector.adoc | 6 ++++-
.../camel-aws2-translate-kafka-sink-connector.adoc | 6 ++++-
...l-google-bigquery-sql-kafka-sink-connector.adoc | 2 +-
.../camel-google-pubsub-kafka-sink-connector.adoc | 9 ++++----
...camel-google-pubsub-kafka-source-connector.adoc | 9 ++++----
...mel-spring-rabbitmq-kafka-source-connector.adoc | 3 ++-
33 files changed, 281 insertions(+), 67 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sts-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sts-sink.json
index 95ad11b..2407404 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sts-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sts-sink.json
@@ -34,6 +34,13 @@
"getFederationToken"
]
},
+ "camel.sink.endpoint.overrideEndpoint": {
+ "name": "camel.sink.endpoint.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.pojoRequest": {
"name": "camel.sink.endpoint.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -84,6 +91,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.uriEndpointOverride": {
+ "name": "camel.sink.endpoint.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -121,6 +134,13 @@
"getFederationToken"
]
},
+ "camel.component.aws2-sts.overrideEndpoint": {
+ "name": "camel.component.aws2-sts.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sts.pojoRequest": {
"name": "camel.component.aws2-sts.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -171,6 +191,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-sts.uriEndpointOverride": {
+ "name": "camel.component.aws2-sts.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sts.autowiredEnabled": {
"name": "camel.component.aws2-sts.autowiredEnabled",
"description": "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.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-translate-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-translate-sink.json
index 58ea322..2fcd8ce 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-translate-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-translate-sink.json
@@ -39,6 +39,13 @@
"translateText"
]
},
+ "camel.sink.endpoint.overrideEndpoint": {
+ "name": "camel.sink.endpoint.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.pojoRequest": {
"name": "camel.sink.endpoint.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -100,6 +107,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.uriEndpointOverride": {
+ "name": "camel.sink.endpoint.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -142,6 +155,13 @@
"translateText"
]
},
+ "camel.component.aws2-translate.overrideEndpoint": {
+ "name":
"camel.component.aws2-translate.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-translate.pojoRequest": {
"name": "camel.component.aws2-translate.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -203,6 +223,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-translate.uriEndpointOverride": {
+ "name":
"camel.component.aws2-translate.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-translate.autowiredEnabled": {
"name":
"camel.component.aws2-translate.autowiredEnabled",
"description": "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.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-bigquery-sql-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-bigquery-sql-sink.json
index b80d60c..883c3d0 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-bigquery-sql-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-bigquery-sql-sink.json
@@ -9,18 +9,18 @@
"description": "Access Google Cloud BigQuery service using SQL
queries."
},
"properties": {
- "camel.sink.path.query": {
- "name": "camel.sink.path.query",
- "description": "BigQuery standard SQL query",
- "priority": "HIGH",
- "required": "true"
- },
"camel.sink.path.projectId": {
"name": "camel.sink.path.projectId",
"description": "Google Cloud Project Id",
"priority": "HIGH",
"required": "true"
},
+ "camel.sink.path.queryString": {
+ "name": "camel.sink.path.queryString",
+ "description": "BigQuery standard SQL query",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.sink.endpoint.connectionFactory": {
"name": "camel.sink.endpoint.connectionFactory",
"description": "ConnectionFactory to obtain connection
to Bigquery Service. If not provided the default one will be used",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-sink.json
index a269fbd..ae5d4c8 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-sink.json
@@ -11,13 +11,13 @@
"properties": {
"camel.sink.path.projectId": {
"name": "camel.sink.path.projectId",
- "description": "Project Id",
+ "description": "The Google Cloud PubSub Project Id",
"priority": "HIGH",
"required": "true"
},
"camel.sink.path.destinationName": {
"name": "camel.sink.path.destinationName",
- "description": "Destination Name",
+ "description": "The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name.",
"priority": "HIGH",
"required": "true"
},
@@ -55,8 +55,8 @@
"camel.sink.endpoint.serviceAccountKey": {
"name": "camel.sink.endpoint.serviceAccountKey",
"description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
- "priority": "MEDIUM",
- "required": "false"
+ "priority": "HIGH",
+ "required": "true"
},
"camel.sink.endpoint.synchronousPull": {
"name": "camel.sink.endpoint.synchronousPull",
@@ -97,6 +97,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.google-pubsub.serviceAccountKey": {
+ "name":
"camel.component.google-pubsub.serviceAccountKey",
+ "description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.component.google-pubsub.lazyStartProducer": {
"name":
"camel.component.google-pubsub.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 [...]
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-source.json
index 203e05a..2d15f15 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-pubsub-source.json
@@ -11,13 +11,13 @@
"properties": {
"camel.source.path.projectId": {
"name": "camel.source.path.projectId",
- "description": "Project Id",
+ "description": "The Google Cloud PubSub Project Id",
"priority": "HIGH",
"required": "true"
},
"camel.source.path.destinationName": {
"name": "camel.source.path.destinationName",
- "description": "Destination Name",
+ "description": "The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name.",
"priority": "HIGH",
"required": "true"
},
@@ -55,8 +55,8 @@
"camel.source.endpoint.serviceAccountKey": {
"name": "camel.source.endpoint.serviceAccountKey",
"description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
- "priority": "MEDIUM",
- "required": "false"
+ "priority": "HIGH",
+ "required": "true"
},
"camel.source.endpoint.synchronousPull": {
"name": "camel.source.endpoint.synchronousPull",
@@ -95,6 +95,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.google-pubsub.serviceAccountKey": {
+ "name":
"camel.component.google-pubsub.serviceAccountKey",
+ "description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.component.google-pubsub.bridgeErrorHandler": {
"name":
"camel.component.google-pubsub.bridgeErrorHandler",
"description": "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.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
index 928e594..adbe1f5 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
@@ -161,6 +161,12 @@
"InOptionalOut"
]
},
+ "camel.source.endpoint.prefetchCount": {
+ "name": "camel.source.endpoint.prefetchCount",
+ "description": "Tell the broker how many messages to
send in a single request. Often this can be set quite high to improve
throughput.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.args": {
"name": "camel.source.endpoint.args",
"description": "Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each element:
arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange.
arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl
argument: args=arg.queue.x-message-ttl=60000",
diff --git
a/connectors/camel-aws2-sts-kafka-connector/src/generated/resources/camel-aws2-sts-sink.json
b/connectors/camel-aws2-sts-kafka-connector/src/generated/resources/camel-aws2-sts-sink.json
index 95ad11b..2407404 100644
---
a/connectors/camel-aws2-sts-kafka-connector/src/generated/resources/camel-aws2-sts-sink.json
+++
b/connectors/camel-aws2-sts-kafka-connector/src/generated/resources/camel-aws2-sts-sink.json
@@ -34,6 +34,13 @@
"getFederationToken"
]
},
+ "camel.sink.endpoint.overrideEndpoint": {
+ "name": "camel.sink.endpoint.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.pojoRequest": {
"name": "camel.sink.endpoint.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -84,6 +91,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.uriEndpointOverride": {
+ "name": "camel.sink.endpoint.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -121,6 +134,13 @@
"getFederationToken"
]
},
+ "camel.component.aws2-sts.overrideEndpoint": {
+ "name": "camel.component.aws2-sts.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sts.pojoRequest": {
"name": "camel.component.aws2-sts.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -171,6 +191,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-sts.uriEndpointOverride": {
+ "name": "camel.component.aws2-sts.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-sts.autowiredEnabled": {
"name": "camel.component.aws2-sts.autowiredEnabled",
"description": "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.",
diff --git
a/connectors/camel-aws2-sts-kafka-connector/src/main/docs/camel-aws2-sts-kafka-sink-connector.adoc
b/connectors/camel-aws2-sts-kafka-connector/src/main/docs/camel-aws2-sts-kafka-sink-connector.adoc
index 2702a1c..357feaf 100644
---
a/connectors/camel-aws2-sts-kafka-connector/src/main/docs/camel-aws2-sts-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-sts-kafka-connector/src/main/docs/camel-aws2-sts-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2sts.CamelAws2stsSinkConnecto
----
-The camel-aws2-sts sink connector supports 25 options, which are listed below.
+The camel-aws2-sts sink connector supports 29 options, which are listed below.
@@ -34,6 +34,7 @@ The camel-aws2-sts sink connector supports 25 options, which
are listed below.
| *camel.sink.path.label* | Logical name | null | true | HIGH
| *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* | The operation to perform One of:
[assumeRole] [getSessionToken] [getFederationToken] | "assumeRole" | true | HIGH
+| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the STS client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the STS client | null | false | MEDIUM
@@ -41,11 +42,13 @@ The camel-aws2-sts sink connector supports 25 options,
which are listed below.
| *camel.sink.endpoint.region* | The region in which STS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | "aws-global" | false | MEDIUM
| *camel.sink.endpoint.stsClient* | To use a existing configured AWS STS as
client | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-sts.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-sts.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
| *camel.component.aws2-sts.operation* | The operation to perform One of:
[assumeRole] [getSessionToken] [getFederationToken] | "assumeRole" | true | HIGH
+| *camel.component.aws2-sts.overrideEndpoint* | Set the need for overidding
the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sts.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
| *camel.component.aws2-sts.proxyHost* | To define a proxy host when
instantiating the STS client | null | false | MEDIUM
| *camel.component.aws2-sts.proxyPort* | To define a proxy port when
instantiating the STS client | null | false | MEDIUM
@@ -53,6 +56,7 @@ The camel-aws2-sts sink connector supports 25 options, which
are listed below.
| *camel.component.aws2-sts.region* | The region in which STS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | "aws-global" | false | MEDIUM
| *camel.component.aws2-sts.stsClient* | To use a existing configured AWS STS
as client | null | false | MEDIUM
| *camel.component.aws2-sts.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.component.aws2-sts.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
| *camel.component.aws2-sts.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-sts.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-sts.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/connectors/camel-aws2-sts-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sts/CamelAws2stsSinkConnectorConfig.java
b/connectors/camel-aws2-sts-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sts/CamelAws2stsSinkConnectorConfig.java
index 736c64d..fe10588 100644
---
a/connectors/camel-aws2-sts-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sts/CamelAws2stsSinkConnectorConfig.java
+++
b/connectors/camel-aws2-sts-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sts/CamelAws2stsSinkConnectorConfig.java
@@ -33,6 +33,9 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_CONF =
"camel.sink.endpoint.operation";
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_DOC =
"The operation to perform One of: [assumeRole] [getSessionToken]
[getFederationToken]";
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_DEFAULT =
"assumeRole";
+ public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_CONF =
"camel.sink.endpoint.overrideEndpoint";
+ public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_DOC = "Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option";
+ public static final Boolean
CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT = false;
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_CONF =
"camel.sink.endpoint.pojoRequest";
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_DOC =
"If we want to use a POJO request as body or not";
public static final Boolean
CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_DEFAULT = false;
@@ -54,6 +57,9 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.sink.endpoint.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
+ public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option";
+ public static final String
CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_CONF =
"camel.sink.endpoint.accessKey";
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_DOC =
"Amazon AWS Access Key";
public static final String CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_DEFAULT
= null;
@@ -69,6 +75,9 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_CONF =
"camel.component.aws2-sts.operation";
public static final String CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_DOC =
"The operation to perform One of: [assumeRole] [getSessionToken]
[getFederationToken]";
public static final String CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_DEFAULT
= "assumeRole";
+ public static final String
CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_CONF =
"camel.component.aws2-sts.overrideEndpoint";
+ public static final String
CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_DOC = "Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option";
+ public static final Boolean
CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT = false;
public static final String CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_CONF
= "camel.component.aws2-sts.pojoRequest";
public static final String CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_DOC =
"If we want to use a POJO request as body or not";
public static final Boolean
CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_DEFAULT = false;
@@ -90,6 +99,9 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-sts.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-sts.uriEndpointOverride";
+ public static final String
CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option";
+ public static final String
CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.aws2-sts.autowiredEnabled";
public static final String
CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -115,6 +127,7 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2STS_PATH_LABEL_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_AWS2STS_PATH_LABEL_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_AWS2STS_PATH_LABEL_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2STS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2STS_ENDPOINT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_PROXY_PORT_DOC);
@@ -122,11 +135,13 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_STS_CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_ENDPOINT_STS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_STS_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
+ conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2STS_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2STS_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2STS_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2STS_COMPONENT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_COMPONENT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_PROXY_PORT_DOC);
@@ -134,6 +149,7 @@ public class CamelAws2stsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_STS_CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2STS_COMPONENT_STS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_STS_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
+ conf.define(CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2STS_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2STS_COMPONENT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2STS_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2STS_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2STS_COMPONENT_SECRET_KEY_DOC);
diff --git
a/connectors/camel-aws2-translate-kafka-connector/src/generated/resources/camel-aws2-translate-sink.json
b/connectors/camel-aws2-translate-kafka-connector/src/generated/resources/camel-aws2-translate-sink.json
index 58ea322..2fcd8ce 100644
---
a/connectors/camel-aws2-translate-kafka-connector/src/generated/resources/camel-aws2-translate-sink.json
+++
b/connectors/camel-aws2-translate-kafka-connector/src/generated/resources/camel-aws2-translate-sink.json
@@ -39,6 +39,13 @@
"translateText"
]
},
+ "camel.sink.endpoint.overrideEndpoint": {
+ "name": "camel.sink.endpoint.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.pojoRequest": {
"name": "camel.sink.endpoint.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -100,6 +107,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.uriEndpointOverride": {
+ "name": "camel.sink.endpoint.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -142,6 +155,13 @@
"translateText"
]
},
+ "camel.component.aws2-translate.overrideEndpoint": {
+ "name":
"camel.component.aws2-translate.overrideEndpoint",
+ "description": "Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-translate.pojoRequest": {
"name": "camel.component.aws2-translate.pojoRequest",
"description": "If we want to use a POJO request as
body or not",
@@ -203,6 +223,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-translate.uriEndpointOverride": {
+ "name":
"camel.component.aws2-translate.uriEndpointOverride",
+ "description": "Set the overriding uri endpoint. This
option needs to be used in combination with overrideEndpoint option",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-translate.autowiredEnabled": {
"name":
"camel.component.aws2-translate.autowiredEnabled",
"description": "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.",
diff --git
a/connectors/camel-aws2-translate-kafka-connector/src/main/docs/camel-aws2-translate-kafka-sink-connector.adoc
b/connectors/camel-aws2-translate-kafka-connector/src/main/docs/camel-aws2-translate-kafka-sink-connector.adoc
index a3ef3f7..e9a0813 100644
---
a/connectors/camel-aws2-translate-kafka-connector/src/main/docs/camel-aws2-translate-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-translate-kafka-connector/src/main/docs/camel-aws2-translate-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2translate.CamelAws2translate
----
-The camel-aws2-translate sink connector supports 31 options, which are listed
below.
+The camel-aws2-translate sink connector supports 35 options, which are listed
below.
@@ -35,6 +35,7 @@ The camel-aws2-translate sink connector supports 31 options,
which are listed be
| *camel.sink.endpoint.autodetectSourceLanguage* | Being able to autodetect
the source language | 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* | The operation to perform One of:
[translateText] | "translateText" | true | HIGH
+| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Translate client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Translate client | null | false | MEDIUM
@@ -44,12 +45,14 @@ The camel-aws2-translate sink connector supports 31
options, which are listed be
| *camel.sink.endpoint.targetLanguage* | Target language to use | null | false
| MEDIUM
| *camel.sink.endpoint.translateClient* | To use a existing configured AWS
Translate as client | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-translate.autodetectSource Language* | Being able to
autodetect the source language | false | false | MEDIUM
| *camel.component.aws2-translate.configuration* | Component configuration |
null | false | MEDIUM
| *camel.component.aws2-translate.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 process [...]
| *camel.component.aws2-translate.operation* | The operation to perform One
of: [translateText] | "translateText" | true | HIGH
+| *camel.component.aws2-translate.overrideEndpoint* | Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-translate.pojoRequest* | If we want to use a POJO
request as body or not | false | false | MEDIUM
| *camel.component.aws2-translate.proxyHost* | To define a proxy host when
instantiating the Translate client | null | false | MEDIUM
| *camel.component.aws2-translate.proxyPort* | To define a proxy port when
instantiating the Translate client | null | false | MEDIUM
@@ -59,6 +62,7 @@ The camel-aws2-translate sink connector supports 31 options,
which are listed be
| *camel.component.aws2-translate.targetLanguage* | Target language to use |
null | false | MEDIUM
| *camel.component.aws2-translate.translateClient* | To use a existing
configured AWS Translate as client | null | false | MEDIUM
| *camel.component.aws2-translate.trustAll Certificates* | If we want to trust
all certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.component.aws2-translate.uriEndpointOverride* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
| *camel.component.aws2-translate.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-translate.accessKey* | Amazon AWS Access Key | null |
false | MEDIUM
| *camel.component.aws2-translate.secretKey* | Amazon AWS Secret Key | null |
false | MEDIUM
diff --git
a/connectors/camel-aws2-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2translate/CamelAws2translateSinkConnectorConfig.java
b/connectors/camel-aws2-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2translate/CamelAws2translateSinkConnectorConfig.java
index 13bdf04..a1ed9d3 100644
---
a/connectors/camel-aws2-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2translate/CamelAws2translateSinkConnectorConfig.java
+++
b/connectors/camel-aws2-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2translate/CamelAws2translateSinkConnectorConfig.java
@@ -38,6 +38,9 @@ public class CamelAws2translateSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_CONF =
"camel.sink.endpoint.operation";
public static final String CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_DOC
= "The operation to perform One of: [translateText]";
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_DEFAULT = "translateText";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_CONF =
"camel.sink.endpoint.overrideEndpoint";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_DOC = "Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option";
+ public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_CONF =
"camel.sink.endpoint.pojoRequest";
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_DOC = "If we want to use a POJO
request as body or not";
public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_DEFAULT = false;
@@ -65,6 +68,9 @@ public class CamelAws2translateSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.sink.endpoint.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to
trust all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC = "Set the
overriding uri endpoint. This option needs to be used in combination with
overrideEndpoint option";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_CONF =
"camel.sink.endpoint.accessKey";
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_DOC = "Amazon AWS Access Key";
public static final String
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_DEFAULT = null;
@@ -83,6 +89,9 @@ public class CamelAws2translateSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_CONF =
"camel.component.aws2-translate.operation";
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_DOC = "The operation to perform
One of: [translateText]";
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_DEFAULT = "translateText";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_CONF =
"camel.component.aws2-translate.overrideEndpoint";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_DOC = "Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option";
+ public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_CONF =
"camel.component.aws2-translate.pojoRequest";
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_DOC = "If we want to use a POJO
request as body or not";
public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_DEFAULT = false;
@@ -110,6 +119,9 @@ public class CamelAws2translateSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-translate.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to
trust all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-translate.uriEndpointOverride";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC = "Set the
overriding uri endpoint. This option needs to be used in combination with
overrideEndpoint option";
+ public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.aws2-translate.autowiredEnabled";
public static final String
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring
is enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -137,6 +149,7 @@ public class CamelAws2translateSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_AUTODETECT_SOURCE_LANGUAGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_AUTODETECT_SOURCE_LANGUAGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_AUTODETECT_SOURCE_LANGUAGE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_PROXY_PORT_DOC);
@@ -146,12 +159,14 @@ public class CamelAws2translateSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TARGET_LANGUAGE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TARGET_LANGUAGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TARGET_LANGUAGE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRANSLATE_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRANSLATE_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRANSLATE_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
+
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTODETECT_SOURCE_LANGUAGE_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTODETECT_SOURCE_LANGUAGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTODETECT_SOURCE_LANGUAGE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OPERATION_DOC);
+ conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_POJO_REQUEST_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_PROXY_PORT_DOC);
@@ -161,6 +176,7 @@ public class CamelAws2translateSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TARGET_LANGUAGE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TARGET_LANGUAGE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TARGET_LANGUAGE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRANSLATE_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRANSLATE_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRANSLATE_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
+
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2TRANSLATE_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2TRANSLATE_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2TRANSLATE_COMPONENT_SECRET_KEY_DOC);
diff --git
a/connectors/camel-google-bigquery-sql-kafka-connector/src/generated/resources/camel-google-bigquery-sql-sink.json
b/connectors/camel-google-bigquery-sql-kafka-connector/src/generated/resources/camel-google-bigquery-sql-sink.json
index b80d60c..883c3d0 100644
---
a/connectors/camel-google-bigquery-sql-kafka-connector/src/generated/resources/camel-google-bigquery-sql-sink.json
+++
b/connectors/camel-google-bigquery-sql-kafka-connector/src/generated/resources/camel-google-bigquery-sql-sink.json
@@ -9,18 +9,18 @@
"description": "Access Google Cloud BigQuery service using SQL
queries."
},
"properties": {
- "camel.sink.path.query": {
- "name": "camel.sink.path.query",
- "description": "BigQuery standard SQL query",
- "priority": "HIGH",
- "required": "true"
- },
"camel.sink.path.projectId": {
"name": "camel.sink.path.projectId",
"description": "Google Cloud Project Id",
"priority": "HIGH",
"required": "true"
},
+ "camel.sink.path.queryString": {
+ "name": "camel.sink.path.queryString",
+ "description": "BigQuery standard SQL query",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.sink.endpoint.connectionFactory": {
"name": "camel.sink.endpoint.connectionFactory",
"description": "ConnectionFactory to obtain connection
to Bigquery Service. If not provided the default one will be used",
diff --git
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/camel-google-bigquery-sql-kafka-sink-connector.adoc
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/camel-google-bigquery-sql-kafka-sink-connector.adoc
index faa2fd3..5cc42d2 100644
---
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/camel-google-bigquery-sql-kafka-sink-connector.adoc
+++
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/camel-google-bigquery-sql-kafka-sink-connector.adoc
@@ -31,8 +31,8 @@ The camel-google-bigquery-sql sink connector supports 8
options, which are liste
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.query* | BigQuery standard SQL query | null | true | HIGH
| *camel.sink.path.projectId* | Google Cloud Project Id | null | true | HIGH
+| *camel.sink.path.queryString* | BigQuery standard SQL query | null | true |
HIGH
| *camel.sink.endpoint.connectionFactory* | ConnectionFactory to obtain
connection to Bigquery Service. If not provided the default one will be used |
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.component.google-bigquery-sql.connection Factory* | ConnectionFactory
to obtain connection to Bigquery Service. If not provided the default one will
be used | null | false | MEDIUM
diff --git
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/examples/CamelGooglebigquerysqlSinkConnector.properties
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/examples/CamelGooglebigquerysqlSinkConnector.properties
index 31ef9dd..e7cff37 100644
---
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/examples/CamelGooglebigquerysqlSinkConnector.properties
+++
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/docs/examples/CamelGooglebigquerysqlSinkConnector.properties
@@ -31,5 +31,5 @@ topics=
# Google Cloud Project Id
camel.sink.path.projectId=
# BigQuery standard SQL query
-camel.sink.path.query=
+camel.sink.path.queryString=
diff --git
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlebigquerysql/CamelGooglebigquerysqlSinkConnectorConfig.java
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlebigquerysql/CamelGooglebigquerysqlSinkConnectorConfig.java
index 300b6e2..e162904 100644
---
a/connectors/camel-google-bigquery-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlebigquerysql/CamelGooglebigquerysqlSinkConnectorConfig.java
+++
b/connectors/camel-google-bigquery-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlebigquerysql/CamelGooglebigquerysqlSinkConnectorConfig.java
@@ -26,12 +26,12 @@ public class CamelGooglebigquerysqlSinkConnectorConfig
extends
CamelSinkConnectorConfig {
- public static final String CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_CONF =
"camel.sink.path.query";
- public static final String CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_DOC =
"BigQuery standard SQL query";
- public static final String CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_DEFAULT
= null;
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_CONF = "camel.sink.path.projectId";
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_DOC = "Google Cloud Project Id";
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_DEFAULT = null;
+ public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_CONF =
"camel.sink.path.queryString";
+ public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_DOC = "BigQuery standard SQL
query";
+ public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_DEFAULT = null;
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_CONF =
"camel.sink.endpoint.connectionFactory";
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_DOC =
"ConnectionFactory to obtain connection to Bigquery Service. If not provided
the default one will be used";
public static final String
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_DEFAULT = null;
@@ -64,8 +64,8 @@ public class CamelGooglebigquerysqlSinkConnectorConfig
public static ConfigDef conf() {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
- conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_DOC);
conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_PROJECT_ID_DOC);
+ conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_GOOGLEBIGQUERYSQL_PATH_QUERY_STRING_DOC);
conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_CONNECTION_FACTORY_DOC);
conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEBIGQUERYSQL_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_GOOGLEBIGQUERYSQL_COMPONENT_CONNECTION_FACTORY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEBIGQUERYSQL_COMPONENT_CONNECTION_FACTORY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEBIGQUERYSQL_COMPONENT_CONNECTION_FACTORY_DOC);
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-sink.json
b/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-sink.json
index a269fbd..ae5d4c8 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-sink.json
+++
b/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-sink.json
@@ -11,13 +11,13 @@
"properties": {
"camel.sink.path.projectId": {
"name": "camel.sink.path.projectId",
- "description": "Project Id",
+ "description": "The Google Cloud PubSub Project Id",
"priority": "HIGH",
"required": "true"
},
"camel.sink.path.destinationName": {
"name": "camel.sink.path.destinationName",
- "description": "Destination Name",
+ "description": "The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name.",
"priority": "HIGH",
"required": "true"
},
@@ -55,8 +55,8 @@
"camel.sink.endpoint.serviceAccountKey": {
"name": "camel.sink.endpoint.serviceAccountKey",
"description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
- "priority": "MEDIUM",
- "required": "false"
+ "priority": "HIGH",
+ "required": "true"
},
"camel.sink.endpoint.synchronousPull": {
"name": "camel.sink.endpoint.synchronousPull",
@@ -97,6 +97,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.google-pubsub.serviceAccountKey": {
+ "name":
"camel.component.google-pubsub.serviceAccountKey",
+ "description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.component.google-pubsub.lazyStartProducer": {
"name":
"camel.component.google-pubsub.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 [...]
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-source.json
b/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-source.json
index 203e05a..2d15f15 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-source.json
+++
b/connectors/camel-google-pubsub-kafka-connector/src/generated/resources/camel-google-pubsub-source.json
@@ -11,13 +11,13 @@
"properties": {
"camel.source.path.projectId": {
"name": "camel.source.path.projectId",
- "description": "Project Id",
+ "description": "The Google Cloud PubSub Project Id",
"priority": "HIGH",
"required": "true"
},
"camel.source.path.destinationName": {
"name": "camel.source.path.destinationName",
- "description": "Destination Name",
+ "description": "The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name.",
"priority": "HIGH",
"required": "true"
},
@@ -55,8 +55,8 @@
"camel.source.endpoint.serviceAccountKey": {
"name": "camel.source.endpoint.serviceAccountKey",
"description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
- "priority": "MEDIUM",
- "required": "false"
+ "priority": "HIGH",
+ "required": "true"
},
"camel.source.endpoint.synchronousPull": {
"name": "camel.source.endpoint.synchronousPull",
@@ -95,6 +95,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.google-pubsub.serviceAccountKey": {
+ "name":
"camel.component.google-pubsub.serviceAccountKey",
+ "description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems.",
+ "priority": "HIGH",
+ "required": "true"
+ },
"camel.component.google-pubsub.bridgeErrorHandler": {
"name":
"camel.component.google-pubsub.bridgeErrorHandler",
"description": "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.",
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-sink-connector.adoc
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-sink-connector.adoc
index 5a44594..e56c714 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-sink-connector.adoc
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-sink-connector.adoc
@@ -24,26 +24,27 @@
connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSi
----
-The camel-google-pubsub sink connector supports 18 options, which are listed
below.
+The camel-google-pubsub sink connector supports 19 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.projectId* | Project Id | null | true | HIGH
-| *camel.sink.path.destinationName* | Destination Name | null | true | HIGH
+| *camel.sink.path.projectId* | The Google Cloud PubSub Project Id | null |
true | HIGH
+| *camel.sink.path.destinationName* | The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name. | null | true | HIGH
| *camel.sink.endpoint.ackMode* | AUTO = exchange gets ack'ed/nack'ed on
completion. NONE = downstream process has to ack/nack explicitly One of: [AUTO]
[NONE] | "AUTO" | false | MEDIUM
| *camel.sink.endpoint.concurrentConsumers* | The number of parallel streams
consuming from the subscription | "1" | false | MEDIUM
| *camel.sink.endpoint.loggerId* | Logger ID to use when a match to the parent
route required | null | false | MEDIUM
| *camel.sink.endpoint.maxMessagesPerPoll* | The max number of messages to
receive from the server in a single API call | "1" | false | MEDIUM
-| *camel.sink.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | false | MEDIUM
+| *camel.sink.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | true | HIGH
| *camel.sink.endpoint.synchronousPull* | Synchronously pull batches of
messages | 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.messageOrderingEnabled* | Should message ordering be
enabled | false | false | MEDIUM
| *camel.sink.endpoint.pubsubEndpoint* | Pub/Sub endpoint to use. Required
when using message ordering, and ensures that messages are received in order
even when multiple publishers are used | null | false | MEDIUM
| *camel.sink.endpoint.serializer* | A custom GooglePubsubSerializer to use
for serializing message payloads in the producer | null | false | MEDIUM
| *camel.component.google-pubsub.endpoint* | Endpoint to use with local
Pub/Sub emulator. | null | false | MEDIUM
+| *camel.component.google-pubsub.serviceAccountKey* | The Service account key
that can be used as credentials for the PubSub publisher/subscriber. It can be
loaded by default from classpath, but you can prefix with classpath:, file:, or
http: to load the resource from different systems. | null | true | HIGH
| *camel.component.google-pubsub.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 processe [...]
| *camel.component.google-pubsub.publisherCacheSize* | Maximum number of
producers to cache. This could be increased if you have producers for lots of
different topics. | null | false | MEDIUM
| *camel.component.google-pubsub.publisherCache Timeout* | How many
milliseconds should each producer stay alive in the cache. | null | false |
MEDIUM
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-source-connector.adoc
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-source-connector.adoc
index 0f1018c..1821bc4 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-source-connector.adoc
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/camel-google-pubsub-kafka-source-connector.adoc
@@ -24,25 +24,26 @@
connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSo
----
-The camel-google-pubsub source connector supports 15 options, which are listed
below.
+The camel-google-pubsub source connector supports 16 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.source.path.projectId* | Project Id | null | true | HIGH
-| *camel.source.path.destinationName* | Destination Name | null | true | HIGH
+| *camel.source.path.projectId* | The Google Cloud PubSub Project Id | null |
true | HIGH
+| *camel.source.path.destinationName* | The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name. | null | true | HIGH
| *camel.source.endpoint.ackMode* | AUTO = exchange gets ack'ed/nack'ed on
completion. NONE = downstream process has to ack/nack explicitly One of: [AUTO]
[NONE] | "AUTO" | false | MEDIUM
| *camel.source.endpoint.concurrentConsumers* | The number of parallel streams
consuming from the subscription | "1" | false | MEDIUM
| *camel.source.endpoint.loggerId* | Logger ID to use when a match to the
parent route required | null | false | MEDIUM
| *camel.source.endpoint.maxMessagesPerPoll* | The max number of messages to
receive from the server in a single API call | "1" | false | MEDIUM
-| *camel.source.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | false | MEDIUM
+| *camel.source.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | true | HIGH
| *camel.source.endpoint.synchronousPull* | Synchronously pull batches of
messages | false | false | MEDIUM
| *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.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.component.google-pubsub.endpoint* | Endpoint to use with local
Pub/Sub emulator. | null | false | MEDIUM
+| *camel.component.google-pubsub.serviceAccountKey* | The Service account key
that can be used as credentials for the PubSub publisher/subscriber. It can be
loaded by default from classpath, but you can prefix with classpath:, file:, or
http: to load the resource from different systems. | null | true | HIGH
| *camel.component.google-pubsub.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.google-pubsub.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.google-pubsub.publisherTermination Timeout* | How many
milliseconds should a producer be allowed to terminate. | null | false | MEDIUM
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSinkConnector.properties
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSinkConnector.properties
index 96afc54..85f993a 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSinkConnector.properties
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSinkConnector.properties
@@ -28,8 +28,12 @@ topics=
# mandatory properties (for a complete properties list see the connector
documentation):
-# Destination Name
+# The Service account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.
+camel.component.google-pubsub.serviceAccountKey=
+# The Service account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.
+camel.sink.endpoint.serviceAccountKey=
+# The Destination Name. For the consumer this will be the subscription name,
while for the producer this will be the topic name.
camel.sink.path.destinationName=
-# Project Id
+# The Google Cloud PubSub Project Id
camel.sink.path.projectId=
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSourceConnector.properties
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSourceConnector.properties
index 578c6f9..60c07d6 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSourceConnector.properties
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/docs/examples/CamelGooglepubsubSourceConnector.properties
@@ -28,8 +28,12 @@ topics=
# mandatory properties (for a complete properties list see the connector
documentation):
-# Destination Name
+# The Service account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.
+camel.component.google-pubsub.serviceAccountKey=
+# The Service account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.
+camel.source.endpoint.serviceAccountKey=
+# The Destination Name. For the consumer this will be the subscription name,
while for the producer this will be the topic name.
camel.source.path.destinationName=
-# Project Id
+# The Google Cloud PubSub Project Id
camel.source.path.projectId=
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSinkConnectorConfig.java
b/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSinkConnectorConfig.java
index 0a34930..9edfacd 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSinkConnectorConfig.java
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSinkConnectorConfig.java
@@ -27,10 +27,10 @@ public class CamelGooglepubsubSinkConnectorConfig
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_GOOGLEPUBSUB_PATH_PROJECT_ID_CONF =
"camel.sink.path.projectId";
- public static final String CAMEL_SINK_GOOGLEPUBSUB_PATH_PROJECT_ID_DOC =
"Project Id";
+ public static final String CAMEL_SINK_GOOGLEPUBSUB_PATH_PROJECT_ID_DOC =
"The Google Cloud PubSub Project Id";
public static final String CAMEL_SINK_GOOGLEPUBSUB_PATH_PROJECT_ID_DEFAULT
= null;
public static final String
CAMEL_SINK_GOOGLEPUBSUB_PATH_DESTINATION_NAME_CONF =
"camel.sink.path.destinationName";
- public static final String
CAMEL_SINK_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DOC = "Destination Name";
+ public static final String
CAMEL_SINK_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DOC = "The Destination Name. For
the consumer this will be the subscription name, while for the producer this
will be the topic name.";
public static final String
CAMEL_SINK_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DEFAULT = null;
public static final String CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_ACK_MODE_CONF
= "camel.sink.endpoint.ackMode";
public static final String CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_ACK_MODE_DOC =
"AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream process
has to ack/nack explicitly One of: [AUTO] [NONE]";
@@ -65,6 +65,9 @@ public class CamelGooglepubsubSinkConnectorConfig
public static final String CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_CONF
= "camel.component.google-pubsub.endpoint";
public static final String CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DOC
= "Endpoint to use with local Pub/Sub emulator.";
public static final String
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DEFAULT = null;
+ public static final String
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_CONF =
"camel.component.google-pubsub.serviceAccountKey";
+ public static final String
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DOC = "The Service
account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.";
+ public static final String
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DEFAULT = null;
public static final String
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.google-pubsub.lazyStartProducer";
public static final String
CAMEL_SINK_GOOGLEPUBSUB_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. Beware t
[...]
public static final Boolean
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -99,13 +102,14 @@ public class CamelGooglepubsubSinkConnectorConfig
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_DOC);
- conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DOC);
+ conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.HIGH,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MESSAGE_ORDERING_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MESSAGE_ORDERING_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_MESSAGE_ORDERING_ENABLED_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_PUBSUB_ENDPOINT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_PUBSUB_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_PUBSUB_ENDPOINT_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERIALIZER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERIALIZER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GOOGLEPUBSUB_ENDPOINT_SERIALIZER_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DOC);
+
conf.define(CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.HIGH,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_SIZE_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_SIZE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_SIZE_DOC);
conf.define(CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_TIMEOUT_CONF,
ConfigDef.Type.INT,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GOOGLEPUBSUB_COMPONENT_PUBLISHER_CACHE_TIMEOUT_DOC);
diff --git
a/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSourceConnectorConfig.java
b/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSourceConnectorConfig.java
index c68694b..d01a80d 100644
---
a/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSourceConnectorConfig.java
+++
b/connectors/camel-google-pubsub-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlepubsub/CamelGooglepubsubSourceConnectorConfig.java
@@ -27,10 +27,10 @@ public class CamelGooglepubsubSourceConnectorConfig
CamelSourceConnectorConfig {
public static final String CAMEL_SOURCE_GOOGLEPUBSUB_PATH_PROJECT_ID_CONF
= "camel.source.path.projectId";
- public static final String CAMEL_SOURCE_GOOGLEPUBSUB_PATH_PROJECT_ID_DOC =
"Project Id";
+ public static final String CAMEL_SOURCE_GOOGLEPUBSUB_PATH_PROJECT_ID_DOC =
"The Google Cloud PubSub Project Id";
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_PATH_PROJECT_ID_DEFAULT = null;
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_PATH_DESTINATION_NAME_CONF =
"camel.source.path.destinationName";
- public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DOC = "Destination Name";
+ public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DOC = "The Destination Name.
For the consumer this will be the subscription name, while for the producer
this will be the topic name.";
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_PATH_DESTINATION_NAME_DEFAULT = null;
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_ACK_MODE_CONF =
"camel.source.endpoint.ackMode";
public static final String CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_ACK_MODE_DOC
= "AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream process
has to ack/nack explicitly One of: [AUTO] [NONE]";
@@ -62,6 +62,9 @@ public class CamelGooglepubsubSourceConnectorConfig
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_CONF =
"camel.component.google-pubsub.endpoint";
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DOC = "Endpoint to use with local
Pub/Sub emulator.";
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_CONF =
"camel.component.google-pubsub.serviceAccountKey";
+ public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DOC = "The Service
account key that can be used as credentials for the PubSub
publisher/subscriber. It can be loaded by default from classpath, but you can
prefix with classpath:, file:, or http: to load the resource from different
systems.";
+ public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DEFAULT = null;
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_CONF =
"camel.component.google-pubsub.bridgeErrorHandler";
public static final String
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_DOC = "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 a [...]
public static final Boolean
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT = false;
@@ -91,12 +94,13 @@ public class CamelGooglepubsubSourceConnectorConfig
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_CONCURRENT_CONSUMERS_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_LOGGER_ID_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_MAX_MESSAGES_PER_POLL_DOC);
-
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DOC);
+
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.HIGH,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SERVICE_ACCOUNT_KEY_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_SYNCHRONOUS_PULL_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_ENDPOINT_EXCHANGE_PATTERN_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_ENDPOINT_DOC);
+
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DEFAULT,
ConfigDef.Importance.HIGH,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_SERVICE_ACCOUNT_KEY_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_PUBLISHER_TERMINATION_TIMEOUT_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_PUBLISHER_TERMINATION_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_GOOGLEPUBSUB_COMPONENT_PUBLISHER_TERMINATION_TIMEOUT_DOC);
diff --git
a/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
b/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
index 928e594..adbe1f5 100644
---
a/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
+++
b/connectors/camel-spring-rabbitmq-kafka-connector/src/generated/resources/camel-spring-rabbitmq-source.json
@@ -161,6 +161,12 @@
"InOptionalOut"
]
},
+ "camel.source.endpoint.prefetchCount": {
+ "name": "camel.source.endpoint.prefetchCount",
+ "description": "Tell the broker how many messages to
send in a single request. Often this can be set quite high to improve
throughput.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.args": {
"name": "camel.source.endpoint.args",
"description": "Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each element:
arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange.
arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl
argument: args=arg.queue.x-message-ttl=60000",
diff --git
a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
index a196246..c3dcc6a 100644
---
a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
+++
b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/docs/camel-spring-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.springrabbitmq.CamelSpringrabbit
----
-The camel-spring-rabbitmq source connector supports 43 options, which are
listed below.
+The camel-spring-rabbitmq source connector supports 44 options, which are
listed below.
@@ -51,6 +51,7 @@ The camel-spring-rabbitmq source connector supports 43
options, which are listed
| *camel.source.endpoint.queues* | The queue(s) to use for consuming messages.
Multiple queue names can be separated by comma. If none has been configured
then Camel will generate an unique id as the queue name for the consumer. |
null | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
+| *camel.source.endpoint.prefetchCount* | Tell the broker how many messages to
send in a single request. Often this can be set quite high to improve
throughput. | null | false | MEDIUM
| *camel.source.endpoint.args* | Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each element:
arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange.
arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl
argument: args=arg.queue.x-message-ttl=60000 | null | false | MEDIUM
| *camel.source.endpoint.messageConverter* | To use a custom MessageConverter
so you can be in control how to map to/from a
org.springframework.amqp.core.Message. | null | false | MEDIUM
| *camel.source.endpoint.messagePropertiesConverter* | To use a custom
MessagePropertiesConverter so you can be in control how to map to/from a
org.springframework.amqp.core.MessageProperties. | null | false | MEDIUM
diff --git
a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
index 65dc5c5..7fd9c41 100644
---
a/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
+++
b/connectors/camel-spring-rabbitmq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/springrabbitmq/CamelSpringrabbitmqSourceConnectorConfig.java
@@ -86,6 +86,9 @@ public class CamelSpringrabbitmqSourceConnectorConfig
public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_CONF =
"camel.source.endpoint.exchangePattern";
public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DOC = "Sets the exchange
pattern when the consumer creates an exchange. One of: [InOnly] [InOut]
[InOptionalOut]";
public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_CONF =
"camel.source.endpoint.prefetchCount";
+ public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DOC = "Tell the broker how
many messages to send in a single request. Often this can be set quite high to
improve throughput.";
+ public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DEFAULT = null;
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_CONF
= "camel.source.endpoint.args";
public static final String CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DOC =
"Specify arguments for configuring the different RabbitMQ concepts, a different
prefix is required for each element: arg.consumer. arg.exchange. arg.queue.
arg.binding. arg.dlq.exchange. arg.dlq.queue. arg.dlq.binding. For example to
declare a queue with message ttl argument: args=arg.queue.x-message-ttl=60000";
public static final String
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DEFAULT = null;
@@ -189,6 +192,7 @@ public class CamelSpringrabbitmqSourceConnectorConfig
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_QUEUES_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_EXCHANGE_PATTERN_DOC);
+ conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_PREFETCH_COUNT_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_ARGS_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_CONVERTER_DOC);
conf.define(CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_PROPERTIES_CONVERTER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_PROPERTIES_CONVERTER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SPRINGRABBITMQ_ENDPOINT_MESSAGE_PROPERTIES_CONVERTER_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-sts-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-sts-kafka-sink-connector.adoc
index 2702a1c..357feaf 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-sts-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-sts-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2sts.CamelAws2stsSinkConnecto
----
-The camel-aws2-sts sink connector supports 25 options, which are listed below.
+The camel-aws2-sts sink connector supports 29 options, which are listed below.
@@ -34,6 +34,7 @@ The camel-aws2-sts sink connector supports 25 options, which
are listed below.
| *camel.sink.path.label* | Logical name | null | true | HIGH
| *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* | The operation to perform One of:
[assumeRole] [getSessionToken] [getFederationToken] | "assumeRole" | true | HIGH
+| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the STS client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the STS client | null | false | MEDIUM
@@ -41,11 +42,13 @@ The camel-aws2-sts sink connector supports 25 options,
which are listed below.
| *camel.sink.endpoint.region* | The region in which STS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | "aws-global" | false | MEDIUM
| *camel.sink.endpoint.stsClient* | To use a existing configured AWS STS as
client | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-sts.configuration* | Component configuration | null |
false | MEDIUM
| *camel.component.aws2-sts.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
| *camel.component.aws2-sts.operation* | The operation to perform One of:
[assumeRole] [getSessionToken] [getFederationToken] | "assumeRole" | true | HIGH
+| *camel.component.aws2-sts.overrideEndpoint* | Set the need for overidding
the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-sts.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
| *camel.component.aws2-sts.proxyHost* | To define a proxy host when
instantiating the STS client | null | false | MEDIUM
| *camel.component.aws2-sts.proxyPort* | To define a proxy port when
instantiating the STS client | null | false | MEDIUM
@@ -53,6 +56,7 @@ The camel-aws2-sts sink connector supports 25 options, which
are listed below.
| *camel.component.aws2-sts.region* | The region in which STS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | "aws-global" | false | MEDIUM
| *camel.component.aws2-sts.stsClient* | To use a existing configured AWS STS
as client | null | false | MEDIUM
| *camel.component.aws2-sts.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.component.aws2-sts.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
| *camel.component.aws2-sts.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-sts.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-sts.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-translate-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-translate-kafka-sink-connector.adoc
index a3ef3f7..e9a0813 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-translate-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-translate-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2translate.CamelAws2translate
----
-The camel-aws2-translate sink connector supports 31 options, which are listed
below.
+The camel-aws2-translate sink connector supports 35 options, which are listed
below.
@@ -35,6 +35,7 @@ The camel-aws2-translate sink connector supports 31 options,
which are listed be
| *camel.sink.endpoint.autodetectSourceLanguage* | Being able to autodetect
the source language | 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* | The operation to perform One of:
[translateText] | "translateText" | true | HIGH
+| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Translate client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Translate client | null | false | MEDIUM
@@ -44,12 +45,14 @@ The camel-aws2-translate sink connector supports 31
options, which are listed be
| *camel.sink.endpoint.targetLanguage* | Target language to use | null | false
| MEDIUM
| *camel.sink.endpoint.translateClient* | To use a existing configured AWS
Translate as client | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-translate.autodetectSource Language* | Being able to
autodetect the source language | false | false | MEDIUM
| *camel.component.aws2-translate.configuration* | Component configuration |
null | false | MEDIUM
| *camel.component.aws2-translate.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 process [...]
| *camel.component.aws2-translate.operation* | The operation to perform One
of: [translateText] | "translateText" | true | HIGH
+| *camel.component.aws2-translate.overrideEndpoint* | Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-translate.pojoRequest* | If we want to use a POJO
request as body or not | false | false | MEDIUM
| *camel.component.aws2-translate.proxyHost* | To define a proxy host when
instantiating the Translate client | null | false | MEDIUM
| *camel.component.aws2-translate.proxyPort* | To define a proxy port when
instantiating the Translate client | null | false | MEDIUM
@@ -59,6 +62,7 @@ The camel-aws2-translate sink connector supports 31 options,
which are listed be
| *camel.component.aws2-translate.targetLanguage* | Target language to use |
null | false | MEDIUM
| *camel.component.aws2-translate.translateClient* | To use a existing
configured AWS Translate as client | null | false | MEDIUM
| *camel.component.aws2-translate.trustAll Certificates* | If we want to trust
all certificates in case of overriding the endpoint | false | false | MEDIUM
+| *camel.component.aws2-translate.uriEndpointOverride* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
| *camel.component.aws2-translate.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.aws2-translate.accessKey* | Amazon AWS Access Key | null |
false | MEDIUM
| *camel.component.aws2-translate.secretKey* | Amazon AWS Secret Key | null |
false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-google-bigquery-sql-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-google-bigquery-sql-kafka-sink-connector.adoc
index faa2fd3..5cc42d2 100644
---
a/docs/modules/ROOT/pages/connectors/camel-google-bigquery-sql-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-google-bigquery-sql-kafka-sink-connector.adoc
@@ -31,8 +31,8 @@ The camel-google-bigquery-sql sink connector supports 8
options, which are liste
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.query* | BigQuery standard SQL query | null | true | HIGH
| *camel.sink.path.projectId* | Google Cloud Project Id | null | true | HIGH
+| *camel.sink.path.queryString* | BigQuery standard SQL query | null | true |
HIGH
| *camel.sink.endpoint.connectionFactory* | ConnectionFactory to obtain
connection to Bigquery Service. If not provided the default one will be used |
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.component.google-bigquery-sql.connection Factory* | ConnectionFactory
to obtain connection to Bigquery Service. If not provided the default one will
be used | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-sink-connector.adoc
index 5a44594..e56c714 100644
---
a/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-sink-connector.adoc
@@ -24,26 +24,27 @@
connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSi
----
-The camel-google-pubsub sink connector supports 18 options, which are listed
below.
+The camel-google-pubsub sink connector supports 19 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.sink.path.projectId* | Project Id | null | true | HIGH
-| *camel.sink.path.destinationName* | Destination Name | null | true | HIGH
+| *camel.sink.path.projectId* | The Google Cloud PubSub Project Id | null |
true | HIGH
+| *camel.sink.path.destinationName* | The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name. | null | true | HIGH
| *camel.sink.endpoint.ackMode* | AUTO = exchange gets ack'ed/nack'ed on
completion. NONE = downstream process has to ack/nack explicitly One of: [AUTO]
[NONE] | "AUTO" | false | MEDIUM
| *camel.sink.endpoint.concurrentConsumers* | The number of parallel streams
consuming from the subscription | "1" | false | MEDIUM
| *camel.sink.endpoint.loggerId* | Logger ID to use when a match to the parent
route required | null | false | MEDIUM
| *camel.sink.endpoint.maxMessagesPerPoll* | The max number of messages to
receive from the server in a single API call | "1" | false | MEDIUM
-| *camel.sink.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | false | MEDIUM
+| *camel.sink.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | true | HIGH
| *camel.sink.endpoint.synchronousPull* | Synchronously pull batches of
messages | 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.messageOrderingEnabled* | Should message ordering be
enabled | false | false | MEDIUM
| *camel.sink.endpoint.pubsubEndpoint* | Pub/Sub endpoint to use. Required
when using message ordering, and ensures that messages are received in order
even when multiple publishers are used | null | false | MEDIUM
| *camel.sink.endpoint.serializer* | A custom GooglePubsubSerializer to use
for serializing message payloads in the producer | null | false | MEDIUM
| *camel.component.google-pubsub.endpoint* | Endpoint to use with local
Pub/Sub emulator. | null | false | MEDIUM
+| *camel.component.google-pubsub.serviceAccountKey* | The Service account key
that can be used as credentials for the PubSub publisher/subscriber. It can be
loaded by default from classpath, but you can prefix with classpath:, file:, or
http: to load the resource from different systems. | null | true | HIGH
| *camel.component.google-pubsub.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 processe [...]
| *camel.component.google-pubsub.publisherCacheSize* | Maximum number of
producers to cache. This could be increased if you have producers for lots of
different topics. | null | false | MEDIUM
| *camel.component.google-pubsub.publisherCache Timeout* | How many
milliseconds should each producer stay alive in the cache. | null | false |
MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-source-connector.adoc
index 0f1018c..1821bc4 100644
---
a/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-google-pubsub-kafka-source-connector.adoc
@@ -24,25 +24,26 @@
connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSo
----
-The camel-google-pubsub source connector supports 15 options, which are listed
below.
+The camel-google-pubsub source connector supports 16 options, which are listed
below.
[width="100%",cols="2,5,^1,1,1",options="header"]
|===
| Name | Description | Default | Required | Priority
-| *camel.source.path.projectId* | Project Id | null | true | HIGH
-| *camel.source.path.destinationName* | Destination Name | null | true | HIGH
+| *camel.source.path.projectId* | The Google Cloud PubSub Project Id | null |
true | HIGH
+| *camel.source.path.destinationName* | The Destination Name. For the consumer
this will be the subscription name, while for the producer this will be the
topic name. | null | true | HIGH
| *camel.source.endpoint.ackMode* | AUTO = exchange gets ack'ed/nack'ed on
completion. NONE = downstream process has to ack/nack explicitly One of: [AUTO]
[NONE] | "AUTO" | false | MEDIUM
| *camel.source.endpoint.concurrentConsumers* | The number of parallel streams
consuming from the subscription | "1" | false | MEDIUM
| *camel.source.endpoint.loggerId* | Logger ID to use when a match to the
parent route required | null | false | MEDIUM
| *camel.source.endpoint.maxMessagesPerPoll* | The max number of messages to
receive from the server in a single API call | "1" | false | MEDIUM
-| *camel.source.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | false | MEDIUM
+| *camel.source.endpoint.serviceAccountKey* | The Service account key that can
be used as credentials for the PubSub publisher/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different systems. | null | true | HIGH
| *camel.source.endpoint.synchronousPull* | Synchronously pull batches of
messages | false | false | MEDIUM
| *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.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
| *camel.component.google-pubsub.endpoint* | Endpoint to use with local
Pub/Sub emulator. | null | false | MEDIUM
+| *camel.component.google-pubsub.serviceAccountKey* | The Service account key
that can be used as credentials for the PubSub publisher/subscriber. It can be
loaded by default from classpath, but you can prefix with classpath:, file:, or
http: to load the resource from different systems. | null | true | HIGH
| *camel.component.google-pubsub.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.google-pubsub.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
| *camel.component.google-pubsub.publisherTermination Timeout* | How many
milliseconds should a producer be allowed to terminate. | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
index a196246..c3dcc6a 100644
---
a/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-spring-rabbitmq-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.springrabbitmq.CamelSpringrabbit
----
-The camel-spring-rabbitmq source connector supports 43 options, which are
listed below.
+The camel-spring-rabbitmq source connector supports 44 options, which are
listed below.
@@ -51,6 +51,7 @@ The camel-spring-rabbitmq source connector supports 43
options, which are listed
| *camel.source.endpoint.queues* | The queue(s) to use for consuming messages.
Multiple queue names can be separated by comma. If none has been configured
then Camel will generate an unique id as the queue name for the consumer. |
null | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
+| *camel.source.endpoint.prefetchCount* | Tell the broker how many messages to
send in a single request. Often this can be set quite high to improve
throughput. | null | false | MEDIUM
| *camel.source.endpoint.args* | Specify arguments for configuring the
different RabbitMQ concepts, a different prefix is required for each element:
arg.consumer. arg.exchange. arg.queue. arg.binding. arg.dlq.exchange.
arg.dlq.queue. arg.dlq.binding. For example to declare a queue with message ttl
argument: args=arg.queue.x-message-ttl=60000 | null | false | MEDIUM
| *camel.source.endpoint.messageConverter* | To use a custom MessageConverter
so you can be in control how to map to/from a
org.springframework.amqp.core.Message. | null | false | MEDIUM
| *camel.source.endpoint.messagePropertiesConverter* | To use a custom
MessagePropertiesConverter so you can be in control how to map to/from a
org.springframework.amqp.core.MessageProperties. | null | false | MEDIUM
