You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/13 06:04:13 UTC
[camel-kafka-connector] branch camel-master updated: Regen
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 d81d262 Regen
d81d262 is described below
commit d81d26256785a9c927b7600af400f853819fe2c2
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 13 08:03:52 2020 +0200
Regen
---
...-sink.json => camel-aws2-eventbridge-sink.json} | 136 ++++++++++++---------
.../camel-aws2-kinesis-firehose-sink.json | 12 ++
.../camel-aws2-kinesis-firehose-sink.json | 12 ++
...aws2-kinesis-firehose-kafka-sink-connector.adoc | 4 +-
...amelAws2kinesisfirehoseSinkConnectorConfig.java | 8 ++
...aws2-kinesis-firehose-kafka-sink-connector.adoc | 4 +-
6 files changed, 118 insertions(+), 58 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
similarity index 56%
copy from camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json
copy to camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
index e76b099..59afd47 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-eventbridge-sink.json
@@ -1,31 +1,37 @@
{
"connector": {
- "class": "org.apache.camel.kafkaconnector.aws2kinesisfirehose.CamelAws2kinesisfirehoseSinkConnector",
- "artifactId": "camel-aws2-kinesis-firehose-kafka-connector",
+ "class": "org.apache.camel.kafkaconnector.aws2eventbridge.CamelAws2eventbridgeSinkConnector",
+ "artifactId": "camel-aws2-eventbridge-kafka-connector",
"groupId": "org.apache.camel.kafkaconnector",
- "id": "camel-aws2-kinesis-firehose-sink",
+ "id": "camel-aws2-eventbridge-sink",
"type": "sink",
"version": "0.6.0-SNAPSHOT"
},
"properties": {
- "camel.sink.path.streamName": {
- "name": "camel.sink.path.streamName",
- "description": "Name of the stream",
+ "camel.sink.path.eventbusNameOrArn": {
+ "name": "camel.sink.path.eventbusNameOrArn",
+ "description": "Event bus name or ARN",
"defaultValue": "null",
"priority": "HIGH"
},
- "camel.sink.endpoint.amazonKinesisFirehoseClient": {
- "name": "camel.sink.endpoint.amazonKinesisFirehoseClient",
- "description": "Amazon Kinesis Firehose client to use for all requests for this endpoint",
- "defaultValue": "null",
- "priority": "MEDIUM"
- },
"camel.sink.endpoint.autoDiscoverClient": {
"name": "camel.sink.endpoint.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking",
+ "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
"defaultValue": "true",
"priority": "MEDIUM"
},
+ "camel.sink.endpoint.eventbridgeClient": {
+ "name": "camel.sink.endpoint.eventbridgeClient",
+ "description": "To use a existing configured AWS Eventbridge as client",
+ "defaultValue": "null",
+ "priority": "MEDIUM"
+ },
+ "camel.sink.endpoint.eventPatternFile": {
+ "name": "camel.sink.endpoint.eventPatternFile",
+ "description": "EventPattern File",
+ "defaultValue": "null",
+ "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 [...]
@@ -34,31 +40,37 @@
},
"camel.sink.endpoint.operation": {
"name": "camel.sink.endpoint.operation",
- "description": "The operation to do in case the user don't want to send only a record One of: [sendBatchRecord] [createDeliveryStream] [deleteDeliveryStream] [describeDeliveryStream] [updateDestination]",
- "defaultValue": "null",
+ "description": "The operation to perform One of: [putRule] [putTargets] [removeTargets] [deleteRule] [enableRule] [disableRule] [describeRule] [listRules] [listTargetsByRule] [listRuleNamesByTarget]",
+ "defaultValue": "\"putRule\"",
+ "priority": "HIGH"
+ },
+ "camel.sink.endpoint.pojoRequest": {
+ "name": "camel.sink.endpoint.pojoRequest",
+ "description": "If we want to use a POJO request as body or not",
+ "defaultValue": "false",
"priority": "MEDIUM"
},
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
- "description": "To define a proxy host when instantiating the Kinesis Firehose client",
+ "description": "To define a proxy host when instantiating the Eventbridge client",
"defaultValue": "null",
"priority": "MEDIUM"
},
"camel.sink.endpoint.proxyPort": {
"name": "camel.sink.endpoint.proxyPort",
- "description": "To define a proxy port when instantiating the Kinesis Firehose client",
+ "description": "To define a proxy port when instantiating the Eventbridge client",
"defaultValue": "null",
"priority": "MEDIUM"
},
"camel.sink.endpoint.proxyProtocol": {
"name": "camel.sink.endpoint.proxyProtocol",
- "description": "To define a proxy protocol when instantiating the Kinesis Firehose client One of: [HTTP] [HTTPS]",
+ "description": "To define a proxy protocol when instantiating the Eventbridge client One of: [HTTP] [HTTPS]",
"defaultValue": "\"HTTPS\"",
"priority": "MEDIUM"
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which Kinesis Firehose 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()",
+ "description": "The region in which Eventbridge 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()",
"defaultValue": "null",
"priority": "MEDIUM"
},
@@ -92,83 +104,95 @@
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.amazonKinesisFirehoseClient": {
- "name": "camel.component.aws2-kinesis-firehose.amazonKinesisFirehoseClient",
- "description": "Amazon Kinesis Firehose client to use for all requests for this endpoint",
+ "camel.component.aws2-eventbridge.autoDiscoverClient": {
+ "name": "camel.component.aws2-eventbridge.autoDiscoverClient",
+ "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
+ "defaultValue": "true",
+ "priority": "MEDIUM"
+ },
+ "camel.component.aws2-eventbridge.configuration": {
+ "name": "camel.component.aws2-eventbridge.configuration",
+ "description": "Component configuration",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.autoDiscoverClient": {
- "name": "camel.component.aws2-kinesis-firehose.autoDiscoverClient",
- "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking",
- "defaultValue": "true",
+ "camel.component.aws2-eventbridge.eventbridgeClient": {
+ "name": "camel.component.aws2-eventbridge.eventbridgeClient",
+ "description": "To use a existing configured AWS Eventbridge as client",
+ "defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.configuration": {
- "name": "camel.component.aws2-kinesis-firehose.configuration",
- "description": "Component configuration",
+ "camel.component.aws2-eventbridge.eventPatternFile": {
+ "name": "camel.component.aws2-eventbridge.eventPatternFile",
+ "description": "EventPattern File",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.lazyStartProducer": {
- "name": "camel.component.aws2-kinesis-firehose.lazyStartProducer",
+ "camel.component.aws2-eventbridge.lazyStartProducer": {
+ "name": "camel.component.aws2-eventbridge.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 [...]
"defaultValue": "false",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.operation": {
- "name": "camel.component.aws2-kinesis-firehose.operation",
- "description": "The operation to do in case the user don't want to send only a record One of: [sendBatchRecord] [createDeliveryStream] [deleteDeliveryStream] [describeDeliveryStream] [updateDestination]",
- "defaultValue": "null",
+ "camel.component.aws2-eventbridge.operation": {
+ "name": "camel.component.aws2-eventbridge.operation",
+ "description": "The operation to perform One of: [putRule] [putTargets] [removeTargets] [deleteRule] [enableRule] [disableRule] [describeRule] [listRules] [listTargetsByRule] [listRuleNamesByTarget]",
+ "defaultValue": "\"putRule\"",
+ "priority": "HIGH"
+ },
+ "camel.component.aws2-eventbridge.pojoRequest": {
+ "name": "camel.component.aws2-eventbridge.pojoRequest",
+ "description": "If we want to use a POJO request as body or not",
+ "defaultValue": "false",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.proxyHost": {
- "name": "camel.component.aws2-kinesis-firehose.proxyHost",
- "description": "To define a proxy host when instantiating the Kinesis Firehose client",
+ "camel.component.aws2-eventbridge.proxyHost": {
+ "name": "camel.component.aws2-eventbridge.proxyHost",
+ "description": "To define a proxy host when instantiating the Eventbridge client",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.proxyPort": {
- "name": "camel.component.aws2-kinesis-firehose.proxyPort",
- "description": "To define a proxy port when instantiating the Kinesis Firehose client",
+ "camel.component.aws2-eventbridge.proxyPort": {
+ "name": "camel.component.aws2-eventbridge.proxyPort",
+ "description": "To define a proxy port when instantiating the Eventbridge client",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.proxyProtocol": {
- "name": "camel.component.aws2-kinesis-firehose.proxyProtocol",
- "description": "To define a proxy protocol when instantiating the Kinesis Firehose client One of: [HTTP] [HTTPS]",
+ "camel.component.aws2-eventbridge.proxyProtocol": {
+ "name": "camel.component.aws2-eventbridge.proxyProtocol",
+ "description": "To define a proxy protocol when instantiating the Eventbridge client One of: [HTTP] [HTTPS]",
"defaultValue": "\"HTTPS\"",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.region": {
- "name": "camel.component.aws2-kinesis-firehose.region",
- "description": "The region in which Kinesis Firehose 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()",
+ "camel.component.aws2-eventbridge.region": {
+ "name": "camel.component.aws2-eventbridge.region",
+ "description": "The region in which Eventbridge 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()",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.trustAllCertificates": {
- "name": "camel.component.aws2-kinesis-firehose.trustAllCertificates",
+ "camel.component.aws2-eventbridge.trustAllCertificates": {
+ "name": "camel.component.aws2-eventbridge.trustAllCertificates",
"description": "If we want to trust all certificates in case of overriding the endpoint",
"defaultValue": "false",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.basicPropertyBinding": {
- "name": "camel.component.aws2-kinesis-firehose.basicPropertyBinding",
+ "camel.component.aws2-eventbridge.basicPropertyBinding": {
+ "name": "camel.component.aws2-eventbridge.basicPropertyBinding",
"description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
"defaultValue": "false",
"priority": "LOW"
},
- "camel.component.aws2-kinesis-firehose.accessKey": {
- "name": "camel.component.aws2-kinesis-firehose.accessKey",
+ "camel.component.aws2-eventbridge.accessKey": {
+ "name": "camel.component.aws2-eventbridge.accessKey",
"description": "Amazon AWS Access Key",
"defaultValue": "null",
"priority": "MEDIUM"
},
- "camel.component.aws2-kinesis-firehose.secretKey": {
- "name": "camel.component.aws2-kinesis-firehose.secretKey",
+ "camel.component.aws2-eventbridge.secretKey": {
+ "name": "camel.component.aws2-eventbridge.secretKey",
"description": "Amazon AWS Secret Key",
"defaultValue": "null",
"priority": "MEDIUM"
}
}
-}
\ No newline at end of file
+}
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json
index e76b099..e3bd2e5 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kinesis-firehose-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/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/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/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