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 <[email protected]> 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
