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 a1c1689 [create-pull-request] automated change
a1c1689 is described below
commit a1c16892cbd5d9d5c619d0e2e37983461994e14e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Oct 13 03:18:13 2020 +0000
[create-pull-request] automated change
---
.../resources/camel-aws2-kinesis-firehose-sink.json | 12 ++++++++++++
.../camel-aws2-kinesis-firehose-kafka-sink-connector.adoc | 4 +++-
.../CamelAws2kinesisfirehoseSinkConnectorConfig.java | 8 ++++++++
.../src/generated/resources/camel-aws2-kinesis-sink.json | 12 ++++++++++++
.../src/generated/resources/camel-aws2-kinesis-source.json | 12 ++++++++++++
.../main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc | 4 +++-
.../main/docs/camel-aws2-kinesis-kafka-source-connector.adoc | 4 +++-
.../aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java | 8 ++++++++
.../aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java | 8 ++++++++
.../camel-aws2-kinesis-firehose-kafka-sink-connector.adoc | 4 +++-
.../connectors/camel-aws2-kinesis-kafka-sink-connector.adoc | 4 +++-
.../camel-aws2-kinesis-kafka-source-connector.adoc | 4 +++-
12 files changed, 78 insertions(+), 6 deletions(-)
diff --git
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/generated/resources/camel-aws2-kinesis-firehose-sink.json
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/generated/resources/camel-aws2-kinesis-firehose-sink.json
index e76b099..e3bd2e5 100644
---
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/generated/resources/camel-aws2-kinesis-firehose-sink.json
+++
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/generated/resources/camel-aws2-kinesis-firehose-sink.json
@@ -26,6 +26,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.sink.endpoint.cborEnabled": {
+ "name": "camel.sink.endpoint.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.sink.endpoint.lazyStartProducer": {
"name": "camel.sink.endpoint.lazyStartProducer",
"description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
@@ -104,6 +110,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.component.aws2-kinesis-firehose.cborEnabled": {
+ "name":
"camel.component.aws2-kinesis-firehose.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.component.aws2-kinesis-firehose.configuration": {
"name":
"camel.component.aws2-kinesis-firehose.configuration",
"description": "Component configuration",
diff --git
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/docs/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/docs/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
index dedc839..214e0e5 100644
---
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/docs/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/docs/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesisfirehose.CamelAws2kin
----
-The camel-aws2-kinesis-firehose sink connector supports 27 options, which are
listed below.
+The camel-aws2-kinesis-firehose sink connector supports 29 options, which are
listed below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis-firehose sink connector supports 27
options, which are li
| *camel.sink.path.streamName* | Name of the stream | null | HIGH
| *camel.sink.endpoint.amazonKinesisFirehoseClient* | Amazon Kinesis Firehose
client to use for all requests for this endpoint | null | MEDIUM
| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.sink.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | 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 do in case the user don't
want to send only a record One of: [sendBatchRecord] [createDeliveryStream]
[deleteDeliveryStream] [describeDeliveryStream] [updateDestination] | null |
MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Kinesis Firehose client | null | MEDIUM
@@ -45,6 +46,7 @@ The camel-aws2-kinesis-firehose sink connector supports 27
options, which are li
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis-firehose.amazon KinesisFirehoseClient* |
Amazon Kinesis Firehose client to use for all requests for this endpoint | null
| MEDIUM
| *camel.component.aws2-kinesis-firehose.autoDiscover Client* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis-firehose.cborEnabled* | This option will set
the CBOR_ENABLED property during the execution | true | MEDIUM
| * camel.component.aws2-kinesis-firehose.configuration* | Component
configuration | null | MEDIUM
| *camel.component.aws2-kinesis-firehose.lazyStart Producer* | Whether the
producer should be started lazy (on the first message). By starting lazy you
can use this to allow CamelContext and routes to startup in situations where a
producer may otherwise fail during starting and cause the route to fail being
started. By deferring this startup to be lazy then the startup failure can be
handled during routing messages via Camel's routing error handlers. Beware that
when the first message is [...]
| *camel.component.aws2-kinesis-firehose.operation* | The operation to do in
case the user don't want to send only a record One of: [sendBatchRecord]
[createDeliveryStream] [deleteDeliveryStream] [describeDeliveryStream]
[updateDestination] | null | MEDIUM
diff --git
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnectorConfig.java
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnectorConfig.java
index a03ab56..d3e82ca 100644
---
a/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnectorConfig.java
+++
b/connectors/camel-aws2-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesisfirehose/CamelAws2kinesisfirehoseSinkConnectorConfig.java
@@ -35,6 +35,9 @@ public class CamelAws2kinesisfirehoseSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF =
"camel.sink.endpoint.autoDiscoverClient";
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_CONF =
"camel.sink.endpoint.cborEnabled";
+ public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_DOC = "This option will
set the CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_DEFAULT = true;
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_CONF =
"camel.sink.endpoint.lazyStartProducer";
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the
producer should be started lazy (on the first message). By starting lazy you
can use this to allow CamelContext and routes to startup in situations where a
producer may otherwise fail during starting and cause the route to fail being
started. By deferring this startup to be lazy then the startup failure can be
handled during routing messages via Camel's routing error handlers. Be [...]
public static final Boolean
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -74,6 +77,9 @@ public class CamelAws2kinesisfirehoseSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF =
"camel.component.aws2-kinesis-firehose.autoDiscoverClient";
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting
the autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_CONF =
"camel.component.aws2-kinesis-firehose.cborEnabled";
+ public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_DOC = "This option will
set the CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_DEFAULT = true;
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_CONF =
"camel.component.aws2-kinesis-firehose.configuration";
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_DOC = "Component
configuration";
public static final String
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -124,6 +130,7 @@ public class CamelAws2kinesisfirehoseSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_PATH_STREAM_NAME_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESISFIREHOSE_PATH_STREAM_NAME_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2KINESISFIREHOSE_PATH_STREAM_NAME_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AMAZON_KINESIS_FIREHOSE_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AMAZON_KINESIS_FIREHOSE_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AMAZON_KINESIS_FIREHOSE_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
+ conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_OPERATION_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_PROXY_HOST_DOC);
@@ -137,6 +144,7 @@ public class CamelAws2kinesisfirehoseSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AMAZON_KINESIS_FIREHOSE_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AMAZON_KINESIS_FIREHOSE_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AMAZON_KINESIS_FIREHOSE_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
+
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_OPERATION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESISFIREHOSE_COMPONENT_OPERATION_DOC);
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-sink.json
b/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-sink.json
index 15b90d4..20c677c 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-sink.json
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-sink.json
@@ -26,6 +26,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.sink.endpoint.cborEnabled": {
+ "name": "camel.sink.endpoint.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
"description": "To define a proxy host when
instantiating the Kinesis client",
@@ -98,6 +104,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.component.aws2-kinesis.cborEnabled": {
+ "name": "camel.component.aws2-kinesis.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.component.aws2-kinesis.configuration": {
"name": "camel.component.aws2-kinesis.configuration",
"description": "Component configuration",
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-source.json
b/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-source.json
index 454f91b..430c8f7 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-source.json
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/generated/resources/camel-aws2-kinesis-source.json
@@ -26,6 +26,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.source.endpoint.cborEnabled": {
+ "name": "camel.source.endpoint.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.source.endpoint.proxyHost": {
"name": "camel.source.endpoint.proxyHost",
"description": "To define a proxy host when
instantiating the Kinesis client",
@@ -236,6 +242,12 @@
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.component.aws2-kinesis.cborEnabled": {
+ "name": "camel.component.aws2-kinesis.cborEnabled",
+ "description": "This option will set the CBOR_ENABLED
property during the execution",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
"camel.component.aws2-kinesis.configuration": {
"name": "camel.component.aws2-kinesis.configuration",
"description": "Component configuration",
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc
index 105a7f5..b8005f2 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesis.CamelAws2kinesisSink
----
-The camel-aws2-kinesis sink connector supports 25 options, which are listed
below.
+The camel-aws2-kinesis sink connector supports 27 options, which are listed
below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis sink connector supports 25 options,
which are listed belo
| *camel.sink.path.streamName* | Name of the stream | null | HIGH
| *camel.sink.endpoint.amazonKinesisClient* | Amazon Kinesis client to use for
all requests for this endpoint | null | MEDIUM
| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.sink.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Kinesis client | null | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Kinesis client | null | MEDIUM
| *camel.sink.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the Kinesis client One of: [HTTP] [HTTPS] | "HTTPS" | MEDIUM
@@ -44,6 +45,7 @@ The camel-aws2-kinesis sink connector supports 25 options,
which are listed belo
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis.amazonKinesisClient* | Amazon Kinesis client
to use for all requests for this endpoint | null | MEDIUM
| *camel.component.aws2-kinesis.autoDiscoverClient* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis.cborEnabled* | This option will set the
CBOR_ENABLED property during the execution | true | MEDIUM
| *camel.component.aws2-kinesis.configuration* | Component configuration |
null | MEDIUM
| *camel.component.aws2-kinesis.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.component.aws2-kinesis.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-source-connector.adoc
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-source-connector.adoc
index 714a9de..aa8f567 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-source-connector.adoc
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/docs/camel-aws2-kinesis-kafka-source-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesis.CamelAws2kinesisSour
----
-The camel-aws2-kinesis source connector supports 53 options, which are listed
below.
+The camel-aws2-kinesis source connector supports 55 options, which are listed
below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis source connector supports 53 options,
which are listed be
| *camel.source.path.streamName* | Name of the stream | null | HIGH
| *camel.source.endpoint.amazonKinesisClient* | Amazon Kinesis client to use
for all requests for this endpoint | null | MEDIUM
| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.source.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | MEDIUM
| *camel.source.endpoint.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.source.endpoint.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
| *camel.source.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the Kinesis client One of: [HTTP] [HTTPS] | "HTTPS" | MEDIUM
@@ -67,6 +68,7 @@ The camel-aws2-kinesis source connector supports 53 options,
which are listed be
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis.amazonKinesisClient* | Amazon Kinesis client
to use for all requests for this endpoint | null | MEDIUM
| *camel.component.aws2-kinesis.autoDiscoverClient* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis.cborEnabled* | This option will set the
CBOR_ENABLED property during the execution | true | MEDIUM
| *camel.component.aws2-kinesis.configuration* | Component configuration |
null | MEDIUM
| *camel.component.aws2-kinesis.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.component.aws2-kinesis.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java
index 3267320..34b5b1c 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSinkConnectorConfig.java
@@ -35,6 +35,9 @@ public class CamelAws2kinesisSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF =
"camel.sink.endpoint.autoDiscoverClient";
public static final String
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_CONF =
"camel.sink.endpoint.cborEnabled";
+ public static final String
CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DOC = "This option will set the
CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DEFAULT = true;
public static final String CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_CONF
= "camel.sink.endpoint.proxyHost";
public static final String CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_DOC
= "To define a proxy host when instantiating the Kinesis client";
public static final String
CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_DEFAULT = null;
@@ -71,6 +74,9 @@ public class CamelAws2kinesisSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF =
"camel.component.aws2-kinesis.autoDiscoverClient";
public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_CONF =
"camel.component.aws2-kinesis.cborEnabled";
+ public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DOC = "This option will set the
CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DEFAULT = true;
public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_CONF =
"camel.component.aws2-kinesis.configuration";
public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_DOC = "Component configuration";
public static final String
CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -117,6 +123,7 @@ public class CamelAws2kinesisSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2KINESIS_PATH_STREAM_NAME_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_PATH_STREAM_NAME_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2KINESIS_PATH_STREAM_NAME_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
+ conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PORT_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_DOC);
@@ -129,6 +136,7 @@ public class CamelAws2kinesisSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2KINESIS_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
+ conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KINESIS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KINESIS_COMPONENT_PROXY_PORT_DOC);
diff --git
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java
index 6431152..29a4e7d 100644
---
a/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java
+++
b/connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/CamelAws2kinesisSourceConnectorConfig.java
@@ -35,6 +35,9 @@ public class CamelAws2kinesisSourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF =
"camel.source.endpoint.autoDiscoverClient";
public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC = "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_CONF =
"camel.source.endpoint.cborEnabled";
+ public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DOC = "This option will set the
CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DEFAULT = true;
public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_CONF =
"camel.source.endpoint.proxyHost";
public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_DOC = "To define a proxy host when
instantiating the Kinesis client";
public static final String
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_DEFAULT = null;
@@ -140,6 +143,9 @@ public class CamelAws2kinesisSourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF =
"camel.component.aws2-kinesis.autoDiscoverClient";
public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC = "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking";
public static final Boolean
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT = true;
+ public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_CONF =
"camel.component.aws2-kinesis.cborEnabled";
+ public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DOC = "This option will set the
CBOR_ENABLED property during the execution";
+ public static final Boolean
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DEFAULT = true;
public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_CONF =
"camel.component.aws2-kinesis.configuration";
public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_DOC = "Component
configuration";
public static final String
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_DEFAULT = null;
@@ -202,6 +208,7 @@ public class CamelAws2kinesisSourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2KINESIS_PATH_STREAM_NAME_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_PATH_STREAM_NAME_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SOURCE_AWS2KINESIS_PATH_STREAM_NAME_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AMAZON_KINESIS_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_AUTO_DISCOVER_CLIENT_DOC);
+ conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PORT_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_PROXY_PROTOCOL_DOC);
@@ -237,6 +244,7 @@ public class CamelAws2kinesisSourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2KINESIS_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AMAZON_KINESIS_CLIENT_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_AUTO_DISCOVER_CLIENT_DOC);
+ conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CBOR_ENABLED_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2KINESIS_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_HOST_DOC);
conf.define(CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2KINESIS_COMPONENT_PROXY_PORT_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
index dedc839..214e0e5 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesisfirehose.CamelAws2kin
----
-The camel-aws2-kinesis-firehose sink connector supports 27 options, which are
listed below.
+The camel-aws2-kinesis-firehose sink connector supports 29 options, which are
listed below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis-firehose sink connector supports 27
options, which are li
| *camel.sink.path.streamName* | Name of the stream | null | HIGH
| *camel.sink.endpoint.amazonKinesisFirehoseClient* | Amazon Kinesis Firehose
client to use for all requests for this endpoint | null | MEDIUM
| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.sink.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | 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 do in case the user don't
want to send only a record One of: [sendBatchRecord] [createDeliveryStream]
[deleteDeliveryStream] [describeDeliveryStream] [updateDestination] | null |
MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Kinesis Firehose client | null | MEDIUM
@@ -45,6 +46,7 @@ The camel-aws2-kinesis-firehose sink connector supports 27
options, which are li
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis-firehose.amazon KinesisFirehoseClient* |
Amazon Kinesis Firehose client to use for all requests for this endpoint | null
| MEDIUM
| *camel.component.aws2-kinesis-firehose.autoDiscover Client* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis-firehose.cborEnabled* | This option will set
the CBOR_ENABLED property during the execution | true | MEDIUM
| * camel.component.aws2-kinesis-firehose.configuration* | Component
configuration | null | MEDIUM
| *camel.component.aws2-kinesis-firehose.lazyStart Producer* | Whether the
producer should be started lazy (on the first message). By starting lazy you
can use this to allow CamelContext and routes to startup in situations where a
producer may otherwise fail during starting and cause the route to fail being
started. By deferring this startup to be lazy then the startup failure can be
handled during routing messages via Camel's routing error handlers. Beware that
when the first message is [...]
| *camel.component.aws2-kinesis-firehose.operation* | The operation to do in
case the user don't want to send only a record One of: [sendBatchRecord]
[createDeliveryStream] [deleteDeliveryStream] [describeDeliveryStream]
[updateDestination] | null | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc
index 105a7f5..b8005f2 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesis.CamelAws2kinesisSink
----
-The camel-aws2-kinesis sink connector supports 25 options, which are listed
below.
+The camel-aws2-kinesis sink connector supports 27 options, which are listed
below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis sink connector supports 25 options,
which are listed belo
| *camel.sink.path.streamName* | Name of the stream | null | HIGH
| *camel.sink.endpoint.amazonKinesisClient* | Amazon Kinesis client to use for
all requests for this endpoint | null | MEDIUM
| *camel.sink.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.sink.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Kinesis client | null | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Kinesis client | null | MEDIUM
| *camel.sink.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the Kinesis client One of: [HTTP] [HTTPS] | "HTTPS" | MEDIUM
@@ -44,6 +45,7 @@ The camel-aws2-kinesis sink connector supports 25 options,
which are listed belo
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis.amazonKinesisClient* | Amazon Kinesis client
to use for all requests for this endpoint | null | MEDIUM
| *camel.component.aws2-kinesis.autoDiscoverClient* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis.cborEnabled* | This option will set the
CBOR_ENABLED property during the execution | true | MEDIUM
| *camel.component.aws2-kinesis.configuration* | Component configuration |
null | MEDIUM
| *camel.component.aws2-kinesis.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.component.aws2-kinesis.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-source-connector.adoc
index 714a9de..aa8f567 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-kinesis-kafka-source-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kinesis.CamelAws2kinesisSour
----
-The camel-aws2-kinesis source connector supports 53 options, which are listed
below.
+The camel-aws2-kinesis source connector supports 55 options, which are listed
below.
@@ -32,6 +32,7 @@ The camel-aws2-kinesis source connector supports 53 options,
which are listed be
| *camel.source.path.streamName* | Name of the stream | null | HIGH
| *camel.source.endpoint.amazonKinesisClient* | Amazon Kinesis client to use
for all requests for this endpoint | null | MEDIUM
| *camel.source.endpoint.autoDiscoverClient* | Setting the autoDiscoverClient
mechanism, if true, the component will look for a client instance in the
registry automatically otherwise it will skip that checking | true | MEDIUM
+| *camel.source.endpoint.cborEnabled* | This option will set the CBOR_ENABLED
property during the execution | true | MEDIUM
| *camel.source.endpoint.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.source.endpoint.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
| *camel.source.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the Kinesis client One of: [HTTP] [HTTPS] | "HTTPS" | MEDIUM
@@ -67,6 +68,7 @@ The camel-aws2-kinesis source connector supports 53 options,
which are listed be
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | MEDIUM
| *camel.component.aws2-kinesis.amazonKinesisClient* | Amazon Kinesis client
to use for all requests for this endpoint | null | MEDIUM
| *camel.component.aws2-kinesis.autoDiscoverClient* | Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the registry automatically otherwise it will skip that checking |
true | MEDIUM
+| *camel.component.aws2-kinesis.cborEnabled* | This option will set the
CBOR_ENABLED property during the execution | true | MEDIUM
| *camel.component.aws2-kinesis.configuration* | Component configuration |
null | MEDIUM
| *camel.component.aws2-kinesis.proxyHost* | To define a proxy host when
instantiating the Kinesis client | null | MEDIUM
| *camel.component.aws2-kinesis.proxyPort* | To define a proxy port when
instantiating the Kinesis client | null | MEDIUM
