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-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new 1695d18 [create-pull-request] automated change
1695d18 is described below
commit 1695d18d3294f7cdef4e0c550410da38628763c8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jan 19 01:15:17 2021 +0000
[create-pull-request] automated change
---
.../catalog/components/aws2-kinesis.json | 4 ++++
.../springboot/catalog/components/milo-client.json | 4 ++++
.../catalog/components/spring-rabbitmq.json | 1 +
.../src/main/docs/aws2-kinesis-starter.adoc | 4 +++-
.../springboot/Kinesis2ComponentConfiguration.java | 26 ++++++++++++++++++++++
docs/modules/ROOT/pages/aws2-kinesis-starter.adoc | 4 +++-
6 files changed, 41 insertions(+), 2 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
index 7ae51d4..82cff0d 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-kinesis.json
@@ -25,11 +25,13 @@
"amazonKinesisClient": { "kind": "property", "displayName": "Amazon
Kinesis Client", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "software.amazon.awssdk.services.kinesis.KinesisClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Amazon Kinesis client to
use for all reques [...]
"cborEnabled": { "kind": "property", "displayName": "Cbor Enabled",
"group": "common", "label": "common", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": 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, "autowired": false, "secret": false, "description":
"Component configuration" },
+ "overrideEndpoint": { "kind": "property", "displayName": "Override
Endpoint", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Set the need for
overidding the endpoint. This option needs to be used in combination wi [...]
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": 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, "autowired": 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": "property", "displayName": "Proxy Protocol",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"HTTPS", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instantia [...]
"region": { "kind": "property", "displayName": "Region", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "The region in which
Kinesis Firehose client needs to work. When using this parameter, the
configuration will expect the lowercase [...]
"trustAllCertificates": { "kind": "property", "displayName": "Trust All
Certificates", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "If we want to trust all
certificates in case of overriding the endpoint" },
+ "uriEndpointOverride": { "kind": "property", "displayName": "Uri Endpoint
Override", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoi [...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"iteratorType": { "kind": "property", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.kinesis.model.ShardIteratorType",
"enum": [ "AT_SEQUENCE_NUMBER", "AFTER_SEQUENCE_NUMBER", "TRIM_HORIZON",
"LATEST", "AT_TIMESTAMP", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "TRIM_HORIZON", "configurationClass":
"org.apache.camel.component.aws2.kinesi [...]
"maxResultsPerRequest": { "kind": "property", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
@@ -45,11 +47,13 @@
"streamName": { "kind": "path", "displayName": "Stream Name", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "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, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Amazon Kinesis client to
use for all reque [...]
"cborEnabled": { "kind": "parameter", "displayName": "Cbor Enabled",
"group": "common", "label": "common", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": 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" },
+ "overrideEndpoint": { "kind": "parameter", "displayName": "Override
Endpoint", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Set the need for
overidding the endpoint. This option needs to be used in combination w [...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": 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, "autowired": 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, "autowired": false, "secret": false, "defaultValue":
"HTTPS", "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instanti [...]
"region": { "kind": "parameter", "displayName": "Region", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "The region in which
Kinesis Firehose client needs to work. When using this parameter, the
configuration will expect the lowercase [...]
"trustAllCertificates": { "kind": "parameter", "displayName": "Trust All
Certificates", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "If we want to trust all
certificates in case of overriding the endpoint" },
+ "uriEndpointOverride": { "kind": "parameter", "displayName": "Uri Endpoint
Override", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpo [...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
"iteratorType": { "kind": "parameter", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.kinesis.model.ShardIteratorType",
"enum": [ "AT_SEQUENCE_NUMBER", "AFTER_SEQUENCE_NUMBER", "TRIM_HORIZON",
"LATEST", "AT_TIMESTAMP", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "TRIM_HORIZON", "configurationClass":
"org.apache.camel.component.aws2.kines [...]
"maxResultsPerRequest": { "kind": "parameter", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/milo-client.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/milo-client.json
index 87610be..58a70f5 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/milo-client.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/milo-client.json
@@ -50,10 +50,14 @@
"properties": {
"endpointUri": { "kind": "path", "displayName": "Endpoint Uri", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The OPC UA server endpoint" },
"clientId": { "kind": "parameter", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.milo.client.MiloClientConfiguration",
"configurationField": "configuration", "description": "A virtual client id to
force the creation of a new connection instance" },
+ "dataChangeFilterDeadbandType": { "kind": "parameter", "displayName":
"Data Change Filter Deadband Type", "group": "common", "label": "", "required":
false, "type": "object", "javaType":
"org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.milo.client.MonitorFilterConfiguration",
"configurationField": "monitorFilterConfiguration", "descripti [...]
+ "dataChangeFilterDeadbandValue": { "kind": "parameter", "displayName":
"Data Change Filter Deadband Value", "group": "common", "label": "",
"required": false, "type": "number", "javaType": "java.lang.Double",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"0.0", "configurationClass":
"org.apache.camel.component.milo.client.MonitorFilterConfiguration",
"configurationField": "monitorFilterConfiguration", "description": "Deadband
value for MonitorFilterType Da [...]
+ "dataChangeFilterTrigger": { "kind": "parameter", "displayName": "Data
Change Filter Trigger", "group": "common", "label": "", "required": false,
"type": "object", "javaType":
"org.eclipse.milo.opcua.stack.core.types.enumerated.DataChangeTrigger", "enum":
[ "Status", "StatusValue", "StatusValueTimestamp" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.milo.client.MonitorFilterConfiguration",
"configurationField": "monitor [...]
"defaultAwaitWrites": { "kind": "parameter", "displayName": "Default Await
Writes", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Default await setting for writes"
},
"discoveryEndpointSuffix": { "kind": "parameter", "displayName":
"Discovery Endpoint Suffix", "group": "common", "label": "", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.milo.client.MiloClientConfiguration",
"configurationField": "configuration", "description": "A suffix for endpoint
URI when discovering" },
"discoveryEndpointUri": { "kind": "parameter", "displayName": "Discovery
Endpoint Uri", "group": "common", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.milo.client.MiloClientConfiguration",
"configurationField": "configuration", "description": "An alternative discovery
URI" },
"method": { "kind": "parameter", "displayName": "Method", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The method definition (see Method ID)" },
+ "monitorFilterType": { "kind": "parameter", "displayName": "Monitor Filter
Type", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.milo.client.MonitorFilterType", "enum":
[ "dataChangeFilter" ], "deprecated": false, "autowired": false, "secret":
false, "configurationClass":
"org.apache.camel.component.milo.client.MonitorFilterConfiguration",
"configurationField": "monitorFilterConfiguration", "description": "Monitor
Filter T [...]
"node": { "kind": "parameter", "displayName": "Node", "group": "common",
"label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "The node definition (see Node ID)" },
"samplingInterval": { "kind": "parameter", "displayName": "Sampling
Interval", "group": "common", "label": "", "required": false, "type": "number",
"javaType": "java.lang.Double", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0.0", "description": "The sampling interval
in milliseconds" },
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a m [...]
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
index 885dec4..898e1b2 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/spring-rabbitmq.json
@@ -66,6 +66,7 @@
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "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 sta [...]
"replyTimeout": { "kind": "parameter", "displayName": "Reply Timeout",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "5000", "description": "Specify the timeout in
milliseconds to be used when waiting for a reply message when doing
request\/reply messaging. The default value is 5 seconds. A negative value
indicates an indefinite timeout." },
+ "usePublisherConnection": { "kind": "parameter", "displayName": "Use
Publisher Connection", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "Use
a separate connection for publishers and consumers" },
"args": { "kind": "parameter", "displayName": "Args", "group": "advanced",
"label": "advanced", "required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "arg.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "Specify arguments for configuring the different RabbitMQ
concepts, a different prefix is required for each element: arg.consumer.
arg.exchange. arg.queue. arg.binding. arg.dlq.ex [...]
"messageConverter": { "kind": "parameter", "displayName": "Message
Converter", "group": "advanced", "label": "advanced", "required": false,
"type": "object", "javaType":
"org.springframework.amqp.support.converter.MessageConverter", "deprecated":
false, "autowired": false, "secret": false, "description": "To use a custom
MessageConverter so you can be in control how to map to\/from a
org.springframework.amqp.core.Message." },
"messagePropertiesConverter": { "kind": "parameter", "displayName":
"Message Properties Converter", "group": "advanced", "label": "advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.component.springrabbit.MessagePropertiesConverter",
"deprecated": false, "autowired": false, "secret": false, "description": "To
use a custom MessagePropertiesConverter so you can be in control how to map
to\/from a org.springframework.amqp.core.MessageProperties." },
diff --git
a/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis-starter.adoc
b/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis-starter.adoc
index a8720fe..96a3f0e 100644
---
a/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis-starter.adoc
+++
b/components-starter/camel-aws2-kinesis-starter/src/main/docs/aws2-kinesis-starter.adoc
@@ -17,7 +17,7 @@ When using aws2-kinesis with Spring Boot make sure to use the
following Maven de
----
-The component supports 33 options, which are listed below.
+The component supports 35 options, which are listed below.
@@ -48,6 +48,7 @@ The component supports 33 options, which are listed below.
| *camel.component.aws2-kinesis.iterator-type* | Defines where in the Kinesis
stream to start getting records | | ShardIteratorType
| *camel.component.aws2-kinesis.lazy-start-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 process [...]
| *camel.component.aws2-kinesis.max-results-per-request* | Maximum number of
records that will be fetched in each poll | 1 | Integer
+| *camel.component.aws2-kinesis.override-endpoint* | Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | Boolean
| *camel.component.aws2-kinesis.proxy-host* | To define a proxy host when
instantiating the Kinesis client | | String
| *camel.component.aws2-kinesis.proxy-port* | To define a proxy port when
instantiating the Kinesis client | | Integer
| *camel.component.aws2-kinesis.proxy-protocol* | To define a proxy protocol
when instantiating the Kinesis client | | Protocol
@@ -57,5 +58,6 @@ The component supports 33 options, which are listed below.
| *camel.component.aws2-kinesis.shard-closed* | Define what will be the
behavior in case of shard closed. Possible value are ignore, silent and fail.
In case of ignore a message will be logged and the consumer will restart from
the beginning,in case of silent there will be no logging and the consumer will
start from the beginning,in case of fail a ReachedClosedStateException will be
raised | | Kinesis2ShardClosedStrategyEnum
| *camel.component.aws2-kinesis.shard-id* | Defines which shardId in the
Kinesis stream to get records from | | String
| *camel.component.aws2-kinesis.trust-all-certificates* | If we want to trust
all certificates in case of overriding the endpoint | false | Boolean
+| *camel.component.aws2-kinesis.uri-endpoint-override* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | | String
|===
// spring-boot-auto-configure options: END
diff --git
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
index 9261ec6..7bd97f7 100644
---
a/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
+++
b/components-starter/camel-aws2-kinesis-starter/src/main/java/org/apache/camel/component/aws2/kinesis/springboot/Kinesis2ComponentConfiguration.java
@@ -58,6 +58,11 @@ public class Kinesis2ComponentConfiguration
*/
private Kinesis2Configuration configuration;
/**
+ * Set the need for overidding the endpoint. This option needs to be used
in
+ * combination with uriEndpointOverride option
+ */
+ private Boolean overrideEndpoint = false;
+ /**
* To define a proxy host when instantiating the Kinesis client
*/
private String proxyHost;
@@ -81,6 +86,11 @@ public class Kinesis2ComponentConfiguration
*/
private Boolean trustAllCertificates = false;
/**
+ * Set the overriding uri endpoint. This option needs to be used in
+ * combination with overrideEndpoint option
+ */
+ private String uriEndpointOverride;
+ /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
pickup
* incoming messages, or the likes, will now be processed as a message and
@@ -167,6 +177,14 @@ public class Kinesis2ComponentConfiguration
this.configuration = configuration;
}
+ public Boolean getOverrideEndpoint() {
+ return overrideEndpoint;
+ }
+
+ public void setOverrideEndpoint(Boolean overrideEndpoint) {
+ this.overrideEndpoint = overrideEndpoint;
+ }
+
public String getProxyHost() {
return proxyHost;
}
@@ -207,6 +225,14 @@ public class Kinesis2ComponentConfiguration
this.trustAllCertificates = trustAllCertificates;
}
+ public String getUriEndpointOverride() {
+ return uriEndpointOverride;
+ }
+
+ public void setUriEndpointOverride(String uriEndpointOverride) {
+ this.uriEndpointOverride = uriEndpointOverride;
+ }
+
public Boolean getBridgeErrorHandler() {
return bridgeErrorHandler;
}
diff --git a/docs/modules/ROOT/pages/aws2-kinesis-starter.adoc
b/docs/modules/ROOT/pages/aws2-kinesis-starter.adoc
index a8720fe..96a3f0e 100644
--- a/docs/modules/ROOT/pages/aws2-kinesis-starter.adoc
+++ b/docs/modules/ROOT/pages/aws2-kinesis-starter.adoc
@@ -17,7 +17,7 @@ When using aws2-kinesis with Spring Boot make sure to use the
following Maven de
----
-The component supports 33 options, which are listed below.
+The component supports 35 options, which are listed below.
@@ -48,6 +48,7 @@ The component supports 33 options, which are listed below.
| *camel.component.aws2-kinesis.iterator-type* | Defines where in the Kinesis
stream to start getting records | | ShardIteratorType
| *camel.component.aws2-kinesis.lazy-start-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 process [...]
| *camel.component.aws2-kinesis.max-results-per-request* | Maximum number of
records that will be fetched in each poll | 1 | Integer
+| *camel.component.aws2-kinesis.override-endpoint* | Set the need for
overidding the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | Boolean
| *camel.component.aws2-kinesis.proxy-host* | To define a proxy host when
instantiating the Kinesis client | | String
| *camel.component.aws2-kinesis.proxy-port* | To define a proxy port when
instantiating the Kinesis client | | Integer
| *camel.component.aws2-kinesis.proxy-protocol* | To define a proxy protocol
when instantiating the Kinesis client | | Protocol
@@ -57,5 +58,6 @@ The component supports 33 options, which are listed below.
| *camel.component.aws2-kinesis.shard-closed* | Define what will be the
behavior in case of shard closed. Possible value are ignore, silent and fail.
In case of ignore a message will be logged and the consumer will restart from
the beginning,in case of silent there will be no logging and the consumer will
start from the beginning,in case of fail a ReachedClosedStateException will be
raised | | Kinesis2ShardClosedStrategyEnum
| *camel.component.aws2-kinesis.shard-id* | Defines which shardId in the
Kinesis stream to get records from | | String
| *camel.component.aws2-kinesis.trust-all-certificates* | If we want to trust
all certificates in case of overriding the endpoint | false | Boolean
+| *camel.component.aws2-kinesis.uri-endpoint-override* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | | String
|===
// spring-boot-auto-configure options: END
