You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/01/30 10:35:56 UTC

(camel-kamelets) 05/06: Support Kafka Batch as Kamelet source - Kafka Not Secured Source as batch

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

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

commit 6cf7636f60ba117be8ad1241e946eecabbc3aa05
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jan 30 11:32:00 2024 +0100

    Support Kafka Batch as Kamelet source - Kafka Not Secured Source as batch
    
    Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
 .../resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
index bef14b00..14cb1040 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/kafka-batch-not-secured-source.kamelet.yaml
@@ -32,7 +32,7 @@ spec:
   definition:
     title: "Kafka Batch Not Secured Source"
     description: |-
-      Receive data from Kafka topics in batch on an insecure broker.
+      Receive data from Kafka topics in batch on an insecure broker and commit them manually through KafkaManualCommit.
     required:
       - topic
       - bootstrapServers
@@ -95,7 +95,7 @@ spec:
       pollTimeout:
         title: The poll timeout interval
         description: The timeout used when polling the KafkaConsumer
-        type: long
+        type: int
         default: 5000
   dependencies:
     - "mvn:org.apache.camel.kamelets:camel-kamelets-utils:4.4.0-SNAPSHOT"
@@ -122,7 +122,6 @@ spec:
         maxPollRecords: "{{batchSize}}"
         pollTimeoutMs: "{{pollTimeout}}"
         batching: true
-        synchronous: true
         kafkaManualCommitFactory: "#bean:{{manualCommitFactory}}"
       steps:
         - process: