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-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new 14a25aa00 Support JetStream in Nats Kamelets (#2537)
14a25aa00 is described below
commit 14a25aa002df4bba92ef6a1e10dce9b4e784055f
Author: Andrea Cosentino <[email protected]>
AuthorDate: Wed Jul 16 11:26:18 2025 +0200
Support JetStream in Nats Kamelets (#2537)
* Support JetStream in Nats Kamelets - Source Kamelet
Signed-off-by: Andrea Cosentino <[email protected]>
* Support JetStream in Nats Kamelets - Sink Kamelet
Signed-off-by: Andrea Cosentino <[email protected]>
---------
Signed-off-by: Andrea Cosentino <[email protected]>
---
kamelets/nats-sink.kamelet.yaml | 17 +++++++++++++++++
kamelets/nats-source.kamelet.yaml | 17 +++++++++++++++++
.../src/main/resources/kamelets/nats-sink.kamelet.yaml | 17 +++++++++++++++++
.../main/resources/kamelets/nats-source.kamelet.yaml | 17 +++++++++++++++++
4 files changed, 68 insertions(+)
diff --git a/kamelets/nats-sink.kamelet.yaml b/kamelets/nats-sink.kamelet.yaml
index c0b7d926b..79165d6d0 100644
--- a/kamelets/nats-sink.kamelet.yaml
+++ b/kamelets/nats-sink.kamelet.yaml
@@ -48,6 +48,20 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
+ jetstreamEnabled:
+ title: Jetstream Enabled
+ description: Sets whether to enable JetStream support for this
endpoint.
+ type: boolean
+ default: false
+ jetstreamName:
+ title: Jetstream Stream Name
+ description: Sets the name of the JetStream stream to use.
+ type: string
+ jetstreamAsync:
+ title: Jetstream Async Enabled
+ description: Sets whether to operate JetStream requests asynchronously.
+ type: boolean
+ default: true
dependencies:
- "camel:nats"
- "camel:kamelet"
@@ -59,3 +73,6 @@ spec:
uri: "nats:{{topic}}"
parameters:
servers: "{{servers}}"
+ jetstreamEnabled: "{{?jetstreamEnabled}}"
+ jetstreamName: "{{?jetstreamName}}"
+ jetstreamAsync: "{{?jetstreamAsync}}"
diff --git a/kamelets/nats-source.kamelet.yaml
b/kamelets/nats-source.kamelet.yaml
index 53158e592..c0dc4a99b 100644
--- a/kamelets/nats-source.kamelet.yaml
+++ b/kamelets/nats-source.kamelet.yaml
@@ -48,6 +48,20 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
+ jetstreamEnabled:
+ title: Jetstream Enabled
+ description: Sets whether to enable JetStream support for this
endpoint.
+ type: boolean
+ default: false
+ jetstreamName:
+ title: Jetstream Stream Name
+ description: Sets the name of the JetStream stream to use.
+ type: string
+ jetstreamAsync:
+ title: Jetstream Async Enabled
+ description: Sets whether to operate JetStream requests asynchronously.
+ type: boolean
+ default: true
types:
out:
mediaType: application/json
@@ -60,6 +74,9 @@ spec:
uri: "nats:{{topic}}"
parameters:
servers: "{{servers}}"
+ jetstreamEnabled: "{{?jetstreamEnabled}}"
+ jetstreamName: "{{?jetstreamName}}"
+ jetstreamAsync: "{{?jetstreamAsync}}"
steps:
- marshal:
json: {}
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/nats-sink.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/nats-sink.kamelet.yaml
index c0b7d926b..79165d6d0 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/nats-sink.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/nats-sink.kamelet.yaml
@@ -48,6 +48,20 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
+ jetstreamEnabled:
+ title: Jetstream Enabled
+ description: Sets whether to enable JetStream support for this
endpoint.
+ type: boolean
+ default: false
+ jetstreamName:
+ title: Jetstream Stream Name
+ description: Sets the name of the JetStream stream to use.
+ type: string
+ jetstreamAsync:
+ title: Jetstream Async Enabled
+ description: Sets whether to operate JetStream requests asynchronously.
+ type: boolean
+ default: true
dependencies:
- "camel:nats"
- "camel:kamelet"
@@ -59,3 +73,6 @@ spec:
uri: "nats:{{topic}}"
parameters:
servers: "{{servers}}"
+ jetstreamEnabled: "{{?jetstreamEnabled}}"
+ jetstreamName: "{{?jetstreamName}}"
+ jetstreamAsync: "{{?jetstreamAsync}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/nats-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/nats-source.kamelet.yaml
index 53158e592..c0dc4a99b 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/nats-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/nats-source.kamelet.yaml
@@ -48,6 +48,20 @@ spec:
format: password
x-descriptors:
- urn:camel:group:credentials
+ jetstreamEnabled:
+ title: Jetstream Enabled
+ description: Sets whether to enable JetStream support for this
endpoint.
+ type: boolean
+ default: false
+ jetstreamName:
+ title: Jetstream Stream Name
+ description: Sets the name of the JetStream stream to use.
+ type: string
+ jetstreamAsync:
+ title: Jetstream Async Enabled
+ description: Sets whether to operate JetStream requests asynchronously.
+ type: boolean
+ default: true
types:
out:
mediaType: application/json
@@ -60,6 +74,9 @@ spec:
uri: "nats:{{topic}}"
parameters:
servers: "{{servers}}"
+ jetstreamEnabled: "{{?jetstreamEnabled}}"
+ jetstreamName: "{{?jetstreamName}}"
+ jetstreamAsync: "{{?jetstreamAsync}}"
steps:
- marshal:
json: {}
