Add Support for Kinesis KCL Consumers to Kinesis Source Kamelet (#2090)

* Add Support for Kinesis KCL Consumers to Kinesis Source Kamelet Signed-off-by: Andrea Cosentino <ancosen@gmail.com> * Moving to Camel 4.7.0-SNAPSHOT Signed-off-by: Andrea Cosentino <ancosen@gmail.com> --------- Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Jun 26, 2024 · acfe23f · acfe23f
1 parent d4cbeeb
commit acfe23f
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 2 deletions.
diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml
@@ -86,6 +86,16 @@ spec:
         description: The number of milliseconds before the next poll of the selected stream.
         type: integer
         default: 500
+      asyncClient:
+        title: Async Client
+        description: If we want to a KinesisAsyncClient instance set it to true.
+        type: boolean
+        default: false
+      useKclConsumers:
+        title: KCL Consumer
+        description: If we want to a KCL Consumer set it to true
+        type: boolean
+        default: false
   types:
     out:
       mediaType: application/octet-stream
@@ -105,5 +115,7 @@ spec:
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
+        useKclConsumers: "{{useKclConsumers}}"
+        asyncClient: "{{asyncClient}}"
       steps:
       - to: "kamelet:sink"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
@@ -86,6 +86,16 @@ spec:
         description: The number of milliseconds before the next poll of the selected stream.
         type: integer
         default: 500
+      asyncClient:
+        title: Async Client
+        description: If we want to a KinesisAsyncClient instance set it to true.
+        type: boolean
+        default: false
+      useKclConsumers:
+        title: KCL Consumer
+        description: If we want to a KCL Consumer set it to true
+        type: boolean
+        default: false
   types:
     out:
       mediaType: application/octet-stream
@@ -105,5 +115,7 @@ spec:
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
+        useKclConsumers: "{{useKclConsumers}}"
+        asyncClient: "{{asyncClient}}"
       steps:
       - to: "kamelet:sink"
diff --git a/pom.xml b/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.camel</groupId>
         <artifactId>camel-dependencies</artifactId>
-        <version>4.6.0</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <groupId>org.apache.camel.kamelets</groupId>
@@ -62,7 +62,7 @@
         <apache-rat-plugin.version>0.16.1</apache-rat-plugin.version>
         <cyclonedx-maven-plugin-version>2.8.0</cyclonedx-maven-plugin-version>
 
-        <camel.version>4.6.0</camel.version>
+        <camel.version>4.7.0-SNAPSHOT</camel.version>
         <camel.k.crds.version>2.3.3</camel.k.crds.version>
 
         <citrus.version>4.2.0</citrus.version>