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 2021/03/02 17:16:21 UTC
[camel-kamelets] 01/02: Added NATS Source Kamelet
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch nats-source
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 41af05a87a0020f2831254306e1eccce3055c4f0
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 2 18:07:33 2021 +0100
Added NATS Source Kamelet
---
nats-source.kamelet.yaml | 40 ++++++++++++++++++++++++++++++++++++++++
1 file changed, 40 insertions(+)
diff --git a/nats-source.kamelet.yaml b/nats-source.kamelet.yaml
new file mode 100644
index 0000000..bcc3f76
--- /dev/null
+++ b/nats-source.kamelet.yaml
@@ -0,0 +1,40 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: nats-source
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHdpZHRoPSI3NDQuMiIgaGVpZ2h0PSIxODEuODEiIHZpZXdCb3g9IjAgMCA3NDQuMiAxODEuODEiPjxkZWZzPjxzdHlsZT4uY2xzLTF7ZmlsbDojMjlhOWRlO30uY2xzLTJ7ZmlsbDojZmZmO30uY2xzLTN7ZmlsbDojMzNhNjc1O30uY2xzLTR7ZmlsbDojMzY1YzkzO30uY2xzLTV7ZmlsbDojOGRjMzQxO308L3N0eWxlPjwvZGVmcz48dGl0bGU+bmF0cy1sb2dvLWZyZWVsb2dvdmVjdG9ycy5uZXQ8L3RpdGxlPjxwYXRoIGNsYXNzPSJjbHMtMS [...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "NATS Source"
+ description: |-
+ Receive data from NATS topics.
+ required:
+ - topic
+ - servers
+ properties:
+ topic:
+ title: Topic name
+ description: NATS Topic name
+ type: string
+ brokers:
+ title: servers
+ description: Comma separated list of NATS Servers
+ type: string
+ types:
+ out:
+ mediaType: application/json
+ dependencies:
+ - "camel:jackson"
+ flow:
+ from:
+ uri: "nats:{{topic}}"
+ parameters:
+ servers: "{{servers}}"
+ steps:
+ - marshal:
+ json: {}
+ - to: "kamelet:sink"