This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new 8b5e699 Basic JMS to Kafka demo.
8b5e699 is described below
commit 8b5e6999a99d6730849401e90defa0cdb06a5d93
Author: Claus Ibsen <[email protected]>
AuthorDate: Mon Sep 26 15:17:14 2022 +0200
Basic JMS to Kafka demo.
---
karavan-demo/jms-to-kafka/docs/README.md | 16 +++++++++++++++-
.../project/{jms2kafka.yaml => payment.yaml} | 4 ++++
2 files changed, 19 insertions(+), 1 deletion(-)
diff --git a/karavan-demo/jms-to-kafka/docs/README.md
b/karavan-demo/jms-to-kafka/docs/README.md
index 159d8c4..e3de1e8 100644
--- a/karavan-demo/jms-to-kafka/docs/README.md
+++ b/karavan-demo/jms-to-kafka/docs/README.md
@@ -29,7 +29,7 @@ docker-compose up
jbang -Dcamel.jbang.version=3.18.2 camel@apache/camel run *
```
-### Publish payment
+### Publish payment to JMS
Open AMQ7 Broker Management [Console](http://localhost:8161)
@@ -42,3 +42,17 @@ Send message to `payments` queue
<status>confirmed</status>
</root>
```
+
+### Browse payments from Kafka
+
+The [kcat](https://github.com/edenhill/kcat) tool can be used to browse
messages in Kafka:
+
+```
+kcat -b localhost -t payments
+```
+
+Which should output the payment that has been transformed to JSon.
+
+```
+{"id":"1","amount":"777","status":"confirmed"}
+```
diff --git a/karavan-demo/jms-to-kafka/project/jms2kafka.yaml
b/karavan-demo/jms-to-kafka/project/payment.yaml
similarity index 76%
rename from karavan-demo/jms-to-kafka/project/jms2kafka.yaml
rename to karavan-demo/jms-to-kafka/project/payment.yaml
index c43eebc..3c633b2 100644
--- a/karavan-demo/jms-to-kafka/project/jms2kafka.yaml
+++ b/karavan-demo/jms-to-kafka/project/payment.yaml
@@ -2,6 +2,10 @@
from:
uri: kamelet:jms-apache-artemis-source
steps:
+ - to:
+ uri: kamelet:xj-identity-action
+ parameters:
+ direction: XML2JSON
- to:
uri: kamelet:kafka-not-secured-sink
parameters:
