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.git
The following commit(s) were added to refs/heads/main by this push: new 726bddde72d Add kinesis batch producer description in kinesis component doc. (#14654) 726bddde72d is described below commit 726bddde72da5790e4b78c7baa95e095835bd3c3 Author: Fan Yang <fan...@hotmail.com> AuthorDate: Thu Jun 27 02:45:08 2024 +0800 Add kinesis batch producer description in kinesis component doc. (#14654) --- .../src/main/docs/aws2-kinesis-component.adoc | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/components/camel-aws/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc b/components/camel-aws/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc index ed15538da3a..2421d44e564 100644 --- a/components/camel-aws/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc +++ b/components/camel-aws/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc @@ -15,8 +15,7 @@ *{component-header}* -The AWS2 Kinesis component supports consuming messages from and producing messages to Amazon Kinesis (no Batch supported) -service. +The AWS2 Kinesis component supports consuming messages from and producing messages to Amazon Kinesis service. The AWS2 Kinesis component also supports Synchronous and Asynchronous Client, which means you choose what fits best your requirements, so if you need the connection (client) to be async, there's a property of 'asyncClient' (in DSL also can be found) needs to be turned true. @@ -74,6 +73,17 @@ all available shards (multiple shards consumption) of Amazon Kinesis, therefore, property in the DSL configuration empty, then it'll consume all available shards otherwise only the specified shard corresponding to the shardId will be consumed. +== Batch Producer + +This component implements the Batch Producer. + +This allows you to send multiple messages in a single request to Amazon Kinesis. +Messages with batch size more than 500 is allowed. Producer will split them into multiple requests. + +The batch type needs to implement the `Iterable` interface. For example, it can be a `List`, `Set` or any other collection type. +The message type can be one or more of types `byte[]`, `ByteBuffer`, UTF-8 `String`, or `InputStream`. Other types are not supported. + + == Usage === Static credentials, Default Credential Provider and Profile Credentials Provider