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 11:09:48 UTC

(camel-kamelets) 03/04: Support Kafka Batch as Kamelet source - Kafka Source as Batch

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

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

commit 0ba944f91ea315944dcf1b982e9a1c1551c74e12
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jan 30 12:04:05 2024 +0100

    Support Kafka Batch as Kamelet source - Kafka Source as Batch
    
    Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
 docs/modules/ROOT/nav.adoc               | 1 +
 kamelets/kafka-batch-source.kamelet.yaml | 4 ++--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index d7be04ed..a90cdbf4 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -133,6 +133,7 @@
 * xref:kafka-azure-schema-registry-source.adoc[]
 * xref:kafka-batch-manual-commit-action.adoc[]
 * xref:kafka-batch-not-secured-source.adoc[]
+* xref:kafka-source.adoc[]
 * xref:kafka-manual-commit-action.adoc[]
 * xref:kafka-not-secured-sink.adoc[]
 * xref:kafka-not-secured-source.adoc[]
diff --git a/kamelets/kafka-batch-source.kamelet.yaml b/kamelets/kafka-batch-source.kamelet.yaml
index 64ba3e63..853e05bb 100644
--- a/kamelets/kafka-batch-source.kamelet.yaml
+++ b/kamelets/kafka-batch-source.kamelet.yaml
@@ -17,7 +17,7 @@
 apiVersion: camel.apache.org/v1
 kind: Kamelet
 metadata:
-  name: kafka-source
+  name: kafka-batch-source
   annotations:
     camel.apache.org/kamelet.support.level: "Stable"
     camel.apache.org/catalog.version: "4.4.0-SNAPSHOT"
@@ -32,7 +32,7 @@ metadata:
     camel.apache.org/kamelet.type: "source"
 spec:
   definition:
-    title: "Kafka Source"
+    title: "Kafka Batch Source"
     description: |-
       Receive data from Kafka topics in batch through Plain Login Module and commit them manually through KafkaManualCommit..
     required: