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 21c6af683b038771988b54b9adc7fc946d93f0d7
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jun 30 14:18:39 2020 +0200
CAMEL-15191 - Docs
---
.../main/docs/aws2-kinesis-firehose-component.adoc | 32 ++++++++++++++++++++++
1 file changed, 32 insertions(+)
diff --git
a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-firehose-component.adoc
b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-firehose-component.adoc
index f423ce9..6c0212a 100644
---
a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-firehose-component.adoc
+++
b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-firehose-component.adoc
@@ -142,6 +142,38 @@ however, a
different
http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/auth/AWSCredentialsProvider.html[AWSCredentialsProvider]
can be specified when calling createClient(...).
+=== Kinesis Firehose Producer operations
+
+Camel-AWS s3 component provides the following operation on the producer side:
+
+- SendBatchRecord
+
+=== Send Batch Records Example
+
+You can send an iterable of Kinesis Record (as the following example shows) or
you can send directly a PutRecordBatchRequest POJO instance in the body.
+
+[source,java]
+--------------------------------------------------------------------------------------------------------------------
+ @Test
+ public void testFirehoseBatchRouting() throws Exception {
+ Exchange exchange = template.send("direct:start",
ExchangePattern.InOnly, new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ List<Record> recs = new ArrayList<Record>();
+ Record rec =
Record.builder().data(SdkBytes.fromString("Test1",
Charset.defaultCharset())).build();
+ Record rec1 =
Record.builder().data(SdkBytes.fromString("Test2",
Charset.defaultCharset())).build();
+ recs.add(rec);
+ recs.add(rec1);
+ exchange.getIn().setBody(recs);
+ }
+ });
+ assertNotNull(exchange.getIn().getBody());
+ }
+
+from("direct:start").to("aws2-kinesis-firehose://cc?amazonKinesisFirehoseClient=#FirehoseClient&operation=sendBatchRecord");
+--------------------------------------------------------------------------------------------------------------------
+
+In the deliveryStream you'll find "Test1Test2".
+
=== Message headers set by the Kinesis producer on successful storage of a
Record
[width="100%",cols="10%,10%,80%",options="header",]
