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 <anco...@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 <anco...@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: