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/12 16:18:49 UTC
[camel] 02/06: CAMEL-15647 - Camel-AWS2-Kinesis-*: Added a
CborEnabled option explicitly, kinesis regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit dee2a10973cd74b8582def3fac64248ddb15cb0c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 12 18:09:22 2020 +0200
CAMEL-15647 - Camel-AWS2-Kinesis-*: Added a CborEnabled option explicitly, kinesis regen
---
.../camel/catalog/docs/aws2-kinesis-component.adoc | 6 +-
.../aws2/kinesis/Kinesis2ComponentConfigurer.java | 5 ++
.../aws2/kinesis/Kinesis2EndpointConfigurer.java | 5 ++
.../aws2/kinesis/Kinesis2EndpointUriFactory.java | 3 +-
.../camel/component/aws2/kinesis/aws2-kinesis.json | 2 +
.../src/main/docs/aws2-kinesis-component.adoc | 6 +-
.../aws2/kinesis/Kinesis2Configuration.java | 18 +++---
.../component/aws2/kinesis/Kinesis2Endpoint.java | 4 +-
.../dsl/Aws2KinesisComponentBuilderFactory.java | 13 ++++
.../dsl/Kinesis2EndpointBuilderFactory.java | 72 ++++++++++++++++++++++
.../modules/ROOT/pages/aws2-kinesis-component.adoc | 6 +-
11 files changed, 122 insertions(+), 18 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kinesis-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kinesis-component.adoc
index cd134c2..6eb04b2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kinesis-component.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-kinesis-component.adoc
@@ -43,7 +43,7 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS 2 Kinesis component supports 18 options, which are listed below.
+The AWS 2 Kinesis component supports 19 options, which are listed below.
@@ -52,6 +52,7 @@ The AWS 2 Kinesis component supports 18 options, which are listed below.
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *configuration* (common) | Component configuration | | Kinesis2Configuration
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
@@ -96,7 +97,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (36 parameters):
+=== Query Parameters (37 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -104,6 +105,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
| *proxyProtocol* (common) | To define a proxy protocol when instantiating the Kinesis client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
diff --git a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
index 59d9784..489b236 100644
--- a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
+++ b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
@@ -20,6 +20,7 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple
Map<String, Object> map = new CaseInsensitiveMap();
map.put("amazonKinesisClient", software.amazon.awssdk.services.kinesis.KinesisClient.class);
map.put("autoDiscoverClient", boolean.class);
+ map.put("cborEnabled", boolean.class);
map.put("configuration", org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class);
map.put("proxyHost", java.lang.String.class);
map.put("proxyPort", java.lang.Integer.class);
@@ -60,6 +61,8 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple
case "basicPropertyBinding": target.setBasicPropertyBinding(property(camelContext, boolean.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
+ case "cborenabled":
+ case "cborEnabled": getOrCreateConfiguration(target).setCborEnabled(property(camelContext, boolean.class, value)); return true;
case "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class, value)); return true;
case "iteratortype":
case "iteratorType": getOrCreateConfiguration(target).setIteratorType(property(camelContext, software.amazon.awssdk.services.kinesis.model.ShardIteratorType.class, value)); return true;
@@ -107,6 +110,8 @@ public class Kinesis2ComponentConfigurer extends PropertyConfigurerSupport imple
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
+ case "cborenabled":
+ case "cborEnabled": return getOrCreateConfiguration(target).isCborEnabled();
case "configuration": return target.getConfiguration();
case "iteratortype":
case "iteratorType": return getOrCreateConfiguration(target).getIteratorType();
diff --git a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
index 70d2655..bf0bba7 100644
--- a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
+++ b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
@@ -21,6 +21,7 @@ public class Kinesis2EndpointConfigurer extends PropertyConfigurerSupport implem
map.put("streamName", java.lang.String.class);
map.put("amazonKinesisClient", software.amazon.awssdk.services.kinesis.KinesisClient.class);
map.put("autoDiscoverClient", boolean.class);
+ map.put("cborEnabled", boolean.class);
map.put("proxyHost", java.lang.String.class);
map.put("proxyPort", java.lang.Integer.class);
map.put("proxyProtocol", software.amazon.awssdk.core.Protocol.class);
@@ -78,6 +79,8 @@ public class Kinesis2EndpointConfigurer extends PropertyConfigurerSupport implem
case "basicPropertyBinding": target.setBasicPropertyBinding(property(camelContext, boolean.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
+ case "cborenabled":
+ case "cborEnabled": target.getConfiguration().setCborEnabled(property(camelContext, boolean.class, value)); return true;
case "delay": target.setDelay(property(camelContext, long.class, value)); return true;
case "exceptionhandler":
case "exceptionHandler": target.setExceptionHandler(property(camelContext, org.apache.camel.spi.ExceptionHandler.class, value)); return true;
@@ -158,6 +161,8 @@ public class Kinesis2EndpointConfigurer extends PropertyConfigurerSupport implem
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
+ case "cborenabled":
+ case "cborEnabled": return target.getConfiguration().isCborEnabled();
case "delay": return target.getDelay();
case "exceptionhandler":
case "exceptionHandler": return target.getExceptionHandler();
diff --git a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointUriFactory.java b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointUriFactory.java
index d0ebd0a..748a6b3 100644
--- a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointUriFactory.java
+++ b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointUriFactory.java
@@ -20,7 +20,7 @@ public class Kinesis2EndpointUriFactory extends org.apache.camel.support.compone
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(37);
+ Set<String> props = new HashSet<>(38);
props.add("basicPropertyBinding");
props.add("backoffMultiplier");
props.add("synchronous");
@@ -32,6 +32,7 @@ public class Kinesis2EndpointUriFactory extends org.apache.camel.support.compone
props.add("runLoggingLevel");
props.add("backoffErrorThreshold");
props.add("amazonKinesisClient");
+ props.add("cborEnabled");
props.add("greedy");
props.add("shardClosed");
props.add("scheduledExecutorService");
diff --git a/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json b/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
index af983f5..bc8e0ce 100644
--- a/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
+++ b/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
@@ -24,6 +24,7 @@
"componentProperties": {
"amazonKinesisClient": { "kind": "property", "displayName": "Amazon Kinesis Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.kinesis.KinesisClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "Amazon Kinesis client to use for all requests for this endpoint" },
"autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in th [...]
+ "cborEnabled": { "kind": "property", "displayName": "Cbor Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "This option will set the CBOR_ENABLED property during the execution" },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "deprecated": false, "secret": false, "description": "Component configuration" },
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the Kinesis client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group": "common", "label": "", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the Kinesis client" },
@@ -45,6 +46,7 @@
"streamName": { "kind": "path", "displayName": "Stream Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "Name of the stream" },
"amazonKinesisClient": { "kind": "parameter", "displayName": "Amazon Kinesis Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.kinesis.KinesisClient", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "Amazon Kinesis client to use for all requests for this endpoint" },
"autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in t [...]
+ "cborEnabled": { "kind": "parameter", "displayName": "Cbor Enabled", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "This option will set the CBOR_ENABLED property during the execution" },
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the Kinesis client" },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group": "common", "label": "", "required": false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "To define a proxy port when instantiating the Kinesis client" },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the Kinesis cl [...]
diff --git a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
index cd134c2..6eb04b2 100644
--- a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
+++ b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
@@ -43,7 +43,7 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS 2 Kinesis component supports 18 options, which are listed below.
+The AWS 2 Kinesis component supports 19 options, which are listed below.
@@ -52,6 +52,7 @@ The AWS 2 Kinesis component supports 18 options, which are listed below.
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *configuration* (common) | Component configuration | | Kinesis2Configuration
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
@@ -96,7 +97,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (36 parameters):
+=== Query Parameters (37 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -104,6 +105,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
| *proxyProtocol* (common) | To define a proxy protocol when instantiating the Kinesis client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol
diff --git a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
index d1607f5..f202e61 100644
--- a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
+++ b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
@@ -70,8 +70,8 @@ public class Kinesis2Configuration implements Cloneable {
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")
private boolean autoDiscoverClient = true;
- @UriParam(label = "common", defaultValue = "true",
- description = "This option will set the CBOR_ENABLED property during the execution")
+ @UriParam(label = "common", defaultValue = "true",
+ description = "This option will set the CBOR_ENABLED property during the execution")
private boolean cborEnabled = true;
public KinesisClient getAmazonKinesisClient() {
@@ -193,19 +193,19 @@ public class Kinesis2Configuration implements Cloneable {
public void setAutoDiscoverClient(boolean autoDiscoverClient) {
this.autoDiscoverClient = autoDiscoverClient;
}
-
+
public boolean isCborEnabled() {
- return cborEnabled;
- }
+ return cborEnabled;
+ }
- public void setCborEnabled(boolean cborEnabled) {
- this.cborEnabled = cborEnabled;
- }
+ public void setCborEnabled(boolean cborEnabled) {
+ this.cborEnabled = cborEnabled;
+ }
// *************************************************
//
// *************************************************
- public Kinesis2Configuration copy() {
+ public Kinesis2Configuration copy() {
try {
return (Kinesis2Configuration) super.clone();
} catch (CloneNotSupportedException e) {
diff --git a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
index 20c8433..4f1ea9b 100644
--- a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
+++ b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java
@@ -63,7 +63,7 @@ public class Kinesis2Endpoint extends ScheduledPollEndpoint {
protected void doStart() throws Exception {
super.doStart();
if (!configuration.isCborEnabled()) {
- System.setProperty(CBOR_ENABLED.property(), "false");
+ System.setProperty(CBOR_ENABLED.property(), "false");
}
kinesisClient = configuration.getAmazonKinesisClient() != null
? configuration.getAmazonKinesisClient() : createKinesisClient();
@@ -84,7 +84,7 @@ public class Kinesis2Endpoint extends ScheduledPollEndpoint {
}
}
if (!configuration.isCborEnabled()) {
- System.clearProperty(CBOR_ENABLED.property());
+ System.clearProperty(CBOR_ENABLED.property());
}
super.doStop();
}
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
index 1f95272..39de344 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
@@ -80,6 +80,18 @@ public interface Aws2KinesisComponentBuilderFactory {
return this;
}
/**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Aws2KinesisComponentBuilder cborEnabled(boolean cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
* Component configuration.
*
* The option is a:
@@ -330,6 +342,7 @@ public interface Aws2KinesisComponentBuilderFactory {
switch (name) {
case "amazonKinesisClient": getOrCreateConfiguration((Kinesis2Component) component).setAmazonKinesisClient((software.amazon.awssdk.services.kinesis.KinesisClient) value); return true;
case "autoDiscoverClient": getOrCreateConfiguration((Kinesis2Component) component).setAutoDiscoverClient((boolean) value); return true;
+ case "cborEnabled": getOrCreateConfiguration((Kinesis2Component) component).setCborEnabled((boolean) value); return true;
case "configuration": ((Kinesis2Component) component).setConfiguration((org.apache.camel.component.aws2.kinesis.Kinesis2Configuration) value); return true;
case "proxyHost": getOrCreateConfiguration((Kinesis2Component) component).setProxyHost((java.lang.String) value); return true;
case "proxyPort": getOrCreateConfiguration((Kinesis2Component) component).setProxyPort((java.lang.Integer) value); return true;
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
index 5a662e5..7da8414 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
@@ -106,6 +106,30 @@ public interface Kinesis2EndpointBuilderFactory {
return this;
}
/**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointConsumerBuilder cborEnabled(boolean cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointConsumerBuilder cborEnabled(String cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
@@ -1023,6 +1047,30 @@ public interface Kinesis2EndpointBuilderFactory {
return this;
}
/**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointProducerBuilder cborEnabled(boolean cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointProducerBuilder cborEnabled(String cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
@@ -1328,6 +1376,30 @@ public interface Kinesis2EndpointBuilderFactory {
return this;
}
/**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointBuilder cborEnabled(boolean cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
+ * This option will set the CBOR_ENABLED property during the execution.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Kinesis2EndpointBuilder cborEnabled(String cborEnabled) {
+ doSetProperty("cborEnabled", cborEnabled);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
diff --git a/docs/components/modules/ROOT/pages/aws2-kinesis-component.adoc b/docs/components/modules/ROOT/pages/aws2-kinesis-component.adoc
index 15e7a8f..9b2001e 100644
--- a/docs/components/modules/ROOT/pages/aws2-kinesis-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-kinesis-component.adoc
@@ -45,7 +45,7 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS 2 Kinesis component supports 18 options, which are listed below.
+The AWS 2 Kinesis component supports 19 options, which are listed below.
@@ -54,6 +54,7 @@ The AWS 2 Kinesis component supports 18 options, which are listed below.
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *configuration* (common) | Component configuration | | Kinesis2Configuration
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
@@ -98,7 +99,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (36 parameters):
+=== Query Parameters (37 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -106,6 +107,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all requests for this endpoint | | KinesisClient
| *autoDiscoverClient* (common) | 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 | boolean
+| *cborEnabled* (common) | This option will set the CBOR_ENABLED property during the execution | true | boolean
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis client | | Integer
| *proxyProtocol* (common) | To define a proxy protocol when instantiating the Kinesis client. There are 2 enums and the value can be one of: HTTP, HTTPS | HTTPS | Protocol