This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new d5006f7 Regen
d5006f7 is described below
commit d5006f79241a86c3f5c29078de48c2041814e2a1
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Sep 24 06:59:36 2021 +0200
Regen
---
.../catalog/components/aws2-ddbstream.json | 6 ++--
.../src/main/docs/aws2-ddb-starter.adoc | 5 ++-
.../Ddb2StreamComponentConfiguration.java | 36 ++++++----------------
.../springboot/Ddb2StreamComponentConverter.java | 2 --
docs/modules/ROOT/pages/aws2-ddb-starter.adoc | 5 ++-
5 files changed, 15 insertions(+), 39 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ddbstream.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ddbstream.json
index f9ccf79..c67317a 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ddbstream.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ddbstream.json
@@ -25,14 +25,13 @@
"amazonDynamoDbStreamsClient": { "kind": "property", "displayName":
"Amazon Dynamo Db Streams Client", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "descripti [...]
"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 [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "consumer", "label": "", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configuration" },
- "iteratorType": { "kind": "property", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.dynamodb.model.ShardIteratorType",
"enum": [ "TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER",
"AFTER_SEQUENCE_NUMBER", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfigu [...]
"maxResultsPerRequest": { "kind": "property", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
"overrideEndpoint": { "kind": "property", "displayName": "Override
Endpoint", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"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":
"consumer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the DDBStreams client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group":
"consumer", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the DDBStreams client" },
"proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol",
"group": "consumer", "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.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "To define a proxy
protocol when ins [...]
"region": { "kind": "property", "displayName": "Region", "group":
"consumer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "The region in which
DDBStreams client needs to work" },
- "sequenceNumberProvider": { "kind": "property", "displayName": "Sequence
Number Provider", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Provider for the
sequence number w [...]
+ "streamIteratorType": { "kind": "property", "displayName": "Stream
Iterator Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration.StreamIteratorType",
"enum": [ "FROM_LATEST", "FROM_START" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "FROM_LATEST", "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration", "conf [...]
"trustAllCertificates": { "kind": "property", "displayName": "Trust All
Certificates", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "If we want to trust all
certificates in case of overriding the endpoint" },
"uriEndpointOverride": { "kind": "property", "displayName": "Uri Endpoint
Override", "group": "consumer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoi [...]
"useDefaultCredentialsProvider": { "kind": "property", "displayName": "Use
Default Credentials Provider", "group": "consumer", "label": "", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Set whether the DynamoDB
Streams client should expect to loa [...]
@@ -44,7 +43,6 @@
"tableName": { "kind": "path", "displayName": "Table Name", "group":
"consumer", "label": "consumer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Name of the dynamodb
table" },
"amazonDynamoDbStreamsClient": { "kind": "parameter", "displayName":
"Amazon Dynamo Db Streams Client", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "descript [...]
"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.dynamodb.model.ShardIteratorType",
"enum": [ "TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER",
"AFTER_SEQUENCE_NUMBER", "null" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfig [...]
"maxResultsPerRequest": { "kind": "parameter", "displayName": "Max Results
Per Request", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Maximum number of
records that will be fetched in each poll" },
"overrideEndpoint": { "kind": "parameter", "displayName": "Override
Endpoint", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"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":
"consumer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the DDBStreams client" },
@@ -52,7 +50,7 @@
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol",
"group": "consumer", "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.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "To define a proxy
protocol when in [...]
"region": { "kind": "parameter", "displayName": "Region", "group":
"consumer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "The region in which
DDBStreams client needs to work" },
"sendEmptyMessageWhenIdle": { "kind": "parameter", "displayName": "Send
Empty Message When Idle", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description": "If
the polling consumer did not poll any files, you can enable this option to send
an empty message (no body) instead." },
- "sequenceNumberProvider": { "kind": "parameter", "displayName": "Sequence
Number Provider", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Provider for the
sequence number [...]
+ "streamIteratorType": { "kind": "parameter", "displayName": "Stream
Iterator Type", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration.StreamIteratorType",
"enum": [ "FROM_LATEST", "FROM_START" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "FROM_LATEST", "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration", "con [...]
"trustAllCertificates": { "kind": "parameter", "displayName": "Trust All
Certificates", "group": "consumer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "If we want to trust all
certificates in case of overriding the endpoint" },
"uriEndpointOverride": { "kind": "parameter", "displayName": "Uri Endpoint
Override", "group": "consumer", "label": "", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpo [...]
"useDefaultCredentialsProvider": { "kind": "parameter", "displayName":
"Use Default Credentials Provider", "group": "consumer", "label": "",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration",
"configurationField": "configuration", "description": "Set whether the DynamoDB
Streams client should expect to lo [...]
diff --git
a/components-starter/camel-aws2-ddb-starter/src/main/docs/aws2-ddb-starter.adoc
b/components-starter/camel-aws2-ddb-starter/src/main/docs/aws2-ddb-starter.adoc
index 61c6285..545a0d0 100644
---
a/components-starter/camel-aws2-ddb-starter/src/main/docs/aws2-ddb-starter.adoc
+++
b/components-starter/camel-aws2-ddb-starter/src/main/docs/aws2-ddb-starter.adoc
@@ -17,7 +17,7 @@ When using aws2-ddb with Spring Boot make sure to use the
following Maven depend
----
-The component supports 40 options, which are listed below.
+The component supports 39 options, which are listed below.
@@ -52,7 +52,6 @@ The component supports 40 options, which are listed below.
| *camel.component.aws2-ddbstream.bridge-error-handler* | 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 handled by the routing Error
Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored. | false | Boolean
| *camel.component.aws2-ddbstream.configuration* | The component
configuration. The option is a
org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration type. | |
Ddb2StreamConfiguration
| *camel.component.aws2-ddbstream.enabled* | Whether to enable auto
configuration of the aws2-ddbstream component. This is enabled by default. | |
Boolean
-| *camel.component.aws2-ddbstream.iterator-type* | Defines where in the
DynaboDB stream to start getting records. Note that using TRIM_HORIZON can
cause a significant delay before the stream has caught up to real-time. if
{AT,AFTER}_SEQUENCE_NUMBER are used, then a sequenceNumberProvider MUST be
supplied. | | ShardIteratorType
| *camel.component.aws2-ddbstream.max-results-per-request* | Maximum number of
records that will be fetched in each poll | | Integer
| *camel.component.aws2-ddbstream.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-ddbstream.proxy-host* | To define a proxy host when
instantiating the DDBStreams client | | String
@@ -60,7 +59,7 @@ The component supports 40 options, which are listed below.
| *camel.component.aws2-ddbstream.proxy-protocol* | To define a proxy protocol
when instantiating the DDBStreams client | | Protocol
| *camel.component.aws2-ddbstream.region* | The region in which DDBStreams
client needs to work | | String
| *camel.component.aws2-ddbstream.secret-key* | Amazon AWS Secret Key | |
String
-| *camel.component.aws2-ddbstream.sequence-number-provider* | Provider for the
sequence number when using one of the two
ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a registry
reference or a literal sequence number. The option is a
org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider type. | |
SequenceNumberProvider
+| *camel.component.aws2-ddbstream.stream-iterator-type* | Defines where in the
DynamoDB stream to start getting records. Note that using FROM_START can cause
a significant delay before the stream has caught up to real-time. | |
Ddb2StreamConfiguration$StreamIteratorType
| *camel.component.aws2-ddbstream.trust-all-certificates* | If we want to
trust all certificates in case of overriding the endpoint | false | Boolean
| *camel.component.aws2-ddbstream.uri-endpoint-override* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | | String
| *camel.component.aws2-ddbstream.use-default-credentials-provider* | Set
whether the DynamoDB Streams client should expect to load credentials through a
default credentials provider or to expect static credentials to be passed in. |
false | Boolean
diff --git
a/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConfiguration.java
b/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConfiguration.java
index 05e7471..0a0cb65 100644
---
a/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConfiguration.java
+++
b/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConfiguration.java
@@ -19,11 +19,10 @@ package
org.apache.camel.component.aws2.ddbstream.springboot;
import javax.annotation.Generated;
import org.apache.camel.component.aws2.ddbstream.Ddb2StreamComponent;
import org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration;
-import org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider;
+import
org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration.StreamIteratorType;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
import software.amazon.awssdk.core.Protocol;
-import software.amazon.awssdk.services.dynamodb.model.ShardIteratorType;
import software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient;
/**
@@ -64,13 +63,6 @@ public class Ddb2StreamComponentConfiguration
*/
private Ddb2StreamConfiguration configuration;
/**
- * Defines where in the DynaboDB stream to start getting records. Note that
- * using TRIM_HORIZON can cause a significant delay before the stream has
- * caught up to real-time. if {AT,AFTER}_SEQUENCE_NUMBER are used, then a
- * sequenceNumberProvider MUST be supplied.
- */
- private ShardIteratorType iteratorType = ShardIteratorType.LATEST;
- /**
* Maximum number of records that will be fetched in each poll
*/
private Integer maxResultsPerRequest;
@@ -96,12 +88,11 @@ public class Ddb2StreamComponentConfiguration
*/
private String region;
/**
- * Provider for the sequence number when using one of the two
- * ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a
- * registry reference or a literal sequence number. The option is a
- * org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider type.
+ * Defines where in the DynamoDB stream to start getting records. Note that
+ * using FROM_START can cause a significant delay before the stream has
+ * caught up to real-time.
*/
- private SequenceNumberProvider sequenceNumberProvider;
+ private StreamIteratorType streamIteratorType =
StreamIteratorType.FROM_LATEST;
/**
* If we want to trust all certificates in case of overriding the endpoint
*/
@@ -160,14 +151,6 @@ public class Ddb2StreamComponentConfiguration
this.configuration = configuration;
}
- public ShardIteratorType getIteratorType() {
- return iteratorType;
- }
-
- public void setIteratorType(ShardIteratorType iteratorType) {
- this.iteratorType = iteratorType;
- }
-
public Integer getMaxResultsPerRequest() {
return maxResultsPerRequest;
}
@@ -216,13 +199,12 @@ public class Ddb2StreamComponentConfiguration
this.region = region;
}
- public SequenceNumberProvider getSequenceNumberProvider() {
- return sequenceNumberProvider;
+ public StreamIteratorType getStreamIteratorType() {
+ return streamIteratorType;
}
- public void setSequenceNumberProvider(
- SequenceNumberProvider sequenceNumberProvider) {
- this.sequenceNumberProvider = sequenceNumberProvider;
+ public void setStreamIteratorType(StreamIteratorType streamIteratorType) {
+ this.streamIteratorType = streamIteratorType;
}
public Boolean getTrustAllCertificates() {
diff --git
a/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConverter.java
b/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConverter.java
index f09cae9..3e42b93 100644
---
a/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConverter.java
+++
b/components-starter/camel-aws2-ddb-starter/src/main/java/org/apache/camel/component/aws2/ddbstream/springboot/Ddb2StreamComponentConverter.java
@@ -43,7 +43,6 @@ public class Ddb2StreamComponentConverter implements
GenericConverter {
Set<ConvertiblePair> answer = new LinkedHashSet<>();
answer.add(new ConvertiblePair(String.class,
software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient.class));
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration.class));
- answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider.class));
return answer;
}
@@ -62,7 +61,6 @@ public class Ddb2StreamComponentConverter implements
GenericConverter {
switch (targetType.getName()) {
case
"software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient":
return applicationContext.getBean(ref,
software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient.class);
case
"org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration": return
applicationContext.getBean(ref,
org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration.class);
- case
"org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider": return
applicationContext.getBean(ref,
org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider.class);
}
return null;
}
diff --git a/docs/modules/ROOT/pages/aws2-ddb-starter.adoc
b/docs/modules/ROOT/pages/aws2-ddb-starter.adoc
index 61c6285..545a0d0 100644
--- a/docs/modules/ROOT/pages/aws2-ddb-starter.adoc
+++ b/docs/modules/ROOT/pages/aws2-ddb-starter.adoc
@@ -17,7 +17,7 @@ When using aws2-ddb with Spring Boot make sure to use the
following Maven depend
----
-The component supports 40 options, which are listed below.
+The component supports 39 options, which are listed below.
@@ -52,7 +52,6 @@ The component supports 40 options, which are listed below.
| *camel.component.aws2-ddbstream.bridge-error-handler* | 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 handled by the routing Error
Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored. | false | Boolean
| *camel.component.aws2-ddbstream.configuration* | The component
configuration. The option is a
org.apache.camel.component.aws2.ddbstream.Ddb2StreamConfiguration type. | |
Ddb2StreamConfiguration
| *camel.component.aws2-ddbstream.enabled* | Whether to enable auto
configuration of the aws2-ddbstream component. This is enabled by default. | |
Boolean
-| *camel.component.aws2-ddbstream.iterator-type* | Defines where in the
DynaboDB stream to start getting records. Note that using TRIM_HORIZON can
cause a significant delay before the stream has caught up to real-time. if
{AT,AFTER}_SEQUENCE_NUMBER are used, then a sequenceNumberProvider MUST be
supplied. | | ShardIteratorType
| *camel.component.aws2-ddbstream.max-results-per-request* | Maximum number of
records that will be fetched in each poll | | Integer
| *camel.component.aws2-ddbstream.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-ddbstream.proxy-host* | To define a proxy host when
instantiating the DDBStreams client | | String
@@ -60,7 +59,7 @@ The component supports 40 options, which are listed below.
| *camel.component.aws2-ddbstream.proxy-protocol* | To define a proxy protocol
when instantiating the DDBStreams client | | Protocol
| *camel.component.aws2-ddbstream.region* | The region in which DDBStreams
client needs to work | | String
| *camel.component.aws2-ddbstream.secret-key* | Amazon AWS Secret Key | |
String
-| *camel.component.aws2-ddbstream.sequence-number-provider* | Provider for the
sequence number when using one of the two
ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a registry
reference or a literal sequence number. The option is a
org.apache.camel.component.aws2.ddbstream.SequenceNumberProvider type. | |
SequenceNumberProvider
+| *camel.component.aws2-ddbstream.stream-iterator-type* | Defines where in the
DynamoDB stream to start getting records. Note that using FROM_START can cause
a significant delay before the stream has caught up to real-time. | |
Ddb2StreamConfiguration$StreamIteratorType
| *camel.component.aws2-ddbstream.trust-all-certificates* | If we want to
trust all certificates in case of overriding the endpoint | false | Boolean
| *camel.component.aws2-ddbstream.uri-endpoint-override* | Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option | | String
| *camel.component.aws2-ddbstream.use-default-credentials-provider* | Set
whether the DynamoDB Streams client should expect to load credentials through a
default credentials provider or to expect static credentials to be passed in. |
false | Boolean
