[camel-k-examples] 01/03: Added a Kafka to Kafka example with manual commit

[ac...@apache.org]

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-k-examples.git

commit 86e965f2cabb155a49b7c95f648859edbb14c777
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jul 19 14:46:54 2021 +0200

    Added a Kafka to Kafka example with manual commit
---
 .../kafka-to-kafka-with-manual-commit/README.md    | 15 +++++++++
 .../flow-binding.yaml                              | 36 ++++++++++++++++++++++
 .../log-sink.kamelet.yaml                          | 22 +++++++++++++
 3 files changed, 73 insertions(+)

diff --git a/kamelets/kafka-to-kafka-with-manual-commit/README.md b/kamelets/kafka-to-kafka-with-manual-commit/README.md
new file mode 100644
index 0000000..5ac06bc
--- /dev/null
+++ b/kamelets/kafka-to-kafka-with-manual-commit/README.md
@@ -0,0 +1,15 @@
+# Kafka to Kafka with manual commit
+
+- Use the quickstart for https://strimzi.io/quickstarts/ and follow the minikube guide.
+
+- Install camel-k on the kafka namespace
+
+- Run the following commands
+
+kubectl apply -f kafka-not-secured-source.kamelet.yaml -n kafka
+kubectl apply -f log-sink.kamelet.yaml -n kafka
+kubectl apply -f flow-binding.yaml -n kafka
+
+- Check logs
+
+kamel logs kafka-to-kafka-with-manual-commit -n kafka
diff --git a/kamelets/kafka-to-kafka-with-manual-commit/flow-binding.yaml b/kamelets/kafka-to-kafka-with-manual-commit/flow-binding.yaml
new file mode 100644
index 0000000..0cc75b6
--- /dev/null
+++ b/kamelets/kafka-to-kafka-with-manual-commit/flow-binding.yaml
@@ -0,0 +1,36 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+  name: kafka-to-log-with-manual-commit
+spec:
+  integration:
+    configuration:
+      - type: property
+        value: "quarkus.log.level=DEBUG"
+  source:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: kafka-not-secured-source
+    properties:
+      brokers: 'my-cluster-kafka-bootstrap:9092'
+      topic: 'test-topic-1'
+      autoCommitEnable: false
+      allowManualCommit: true
+  steps:
+  - ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: kafka-not-secured-sink
+    properties:
+      brokers: 'my-cluster-kafka-bootstrap:9092'
+      topic: 'test-topic-2'
+  - ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: kafka-manual-commit-action
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: log-sink
diff --git a/kamelets/kafka-to-kafka-with-manual-commit/log-sink.kamelet.yaml b/kamelets/kafka-to-kafka-with-manual-commit/log-sink.kamelet.yaml
new file mode 100755
index 0000000..a48fb41
--- /dev/null
+++ b/kamelets/kafka-to-kafka-with-manual-commit/log-sink.kamelet.yaml
@@ -0,0 +1,22 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+  name: log-sink
+  annotations:
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHZpZXdCb3g9IjAgMCAyNDAgMjQwIj48ZGVmcz48bGluZWFyR3JhZGllbnQgaWQ9ImEiIHgxPSIuNjY3IiB4Mj0iLjQxNyIgeTE9Ii4xNjciIHkyPSIuNzUiPjxzdG9wIG9mZnNldD0iMCIgc3RvcC1jb2xvcj0iIzM3YWVlMiIvPjxzdG9wIG9mZnNldD0iMSIgc3RvcC1jb2xvcj0iIzFlOTZjOCIvPjwvbGluZWFyR3JhZGllbnQ+PGxpbmVhckdyYWRpZW50IGlkPSJiIiB4MT0iLjY2IiB4Mj0iLjg1MSIgeTE9Ii40MzciIHkyPSIuODAyIj48c3RvcCBvZmZzZXQ9IjAiIHN0b3AtY29sb3I9IiNlZmY3Zm [...]
+    camel.apache.org/provider: "Apache Software Foundation"
+  labels:
+    camel.apache.org/kamelet.type: "sink"
+    camel.apache.org/kamelet.group: "Log"
+spec:
+  definition:
+    title: "Log Sink"
+    description: |-
+      Log something
+    type: object
+  flow:
+    from:
+      uri: "kamelet:source"
+      steps:
+      - to:
+          uri: "log:info?showAll=true"