(camel-kamelets-examples) branch main updated: Added AWS Kinesis KCL Consumer to AWS Kinesis log example

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets-examples.git


The following commit(s) were added to refs/heads/main by this push:
     new b767483  Added AWS Kinesis KCL Consumer to AWS Kinesis log example
b767483 is described below

commit b76748382cef47dcefa789912318a6054a523a5a
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jul 26 12:13:10 2024 +0200

    Added AWS Kinesis KCL Consumer to AWS Kinesis log example
    
    Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
 .../aws-kinesis-kcl-log.camel.yaml}                    | 18 ++++++++----------
 jbang/timer-activemq-artemis/timer-artemis.camel.yaml  |  1 +
 2 files changed, 9 insertions(+), 10 deletions(-)

diff --git a/jbang/timer-activemq-artemis/timer-artemis.camel.yaml 
b/jbang/aws-kinesis-log/aws-kinesis-kcl-log.camel.yaml
similarity index 72%
copy from jbang/timer-activemq-artemis/timer-artemis.camel.yaml
copy to jbang/aws-kinesis-log/aws-kinesis-kcl-log.camel.yaml
index 479e50f..5df794d 100644
--- a/jbang/timer-activemq-artemis/timer-artemis.camel.yaml
+++ b/jbang/aws-kinesis-log/aws-kinesis-kcl-log.camel.yaml
@@ -17,17 +17,15 @@
 
 - route:
     from:
-      uri: "kamelet:timer-source"
+      uri: "kamelet:aws-kinesis-source"
       parameters:
-        message: '{"id":"1","message":"Camel Rocks"}'
-        contentType: "application/json"
-        repeatCount: 10
+        stream: "kinesis-kamelets"
+        useDefaultCredentialsProvider: true
+        region: "eu-west-1"
+        asyncClient: true
+        useKclConsumers: true
       steps:
       - to: 
-          uri: "kamelet:jms-pooled-apache-artemis-sink"
+          uri: "kamelet:log-sink"
           parameters:
-            brokerURL: "tcp://localhost:61616"
-            destinationName: "queue-test"
-            destinationType: "queue"
-            username: "artemis"
-            password: "artemis"
+            showHeaders: true
diff --git a/jbang/timer-activemq-artemis/timer-artemis.camel.yaml 
b/jbang/timer-activemq-artemis/timer-artemis.camel.yaml
index 479e50f..7955c1d 100644
--- a/jbang/timer-activemq-artemis/timer-artemis.camel.yaml
+++ b/jbang/timer-activemq-artemis/timer-artemis.camel.yaml
@@ -31,3 +31,4 @@
             destinationType: "queue"
             username: "artemis"
             password: "artemis"
+            maxSessionsPerConnection: 1000