This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch jetstream-nats in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit b41c377ec85c74192c50bff3482adef7f8047511 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Jul 16 11:05:32 2025 +0200 Support JetStream in Nats Kamelets - Sink Kamelet Signed-off-by: Andrea Cosentino <[email protected]> --- kamelets/nats-sink.kamelet.yaml | 17 +++++++++++++++++ .../src/main/resources/kamelets/nats-sink.kamelet.yaml | 17 +++++++++++++++++ 2 files changed, 34 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/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}}"
