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 c786ab9169bd72da7dea770e2850e05bbad60fd0 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Jul 16 11:04:17 2025 +0200 Support JetStream in Nats Kamelets - Source Kamelet Signed-off-by: Andrea Cosentino <[email protected]> --- kamelets/nats-source.kamelet.yaml | 17 +++++++++++++++++ .../main/resources/kamelets/nats-source.kamelet.yaml | 17 +++++++++++++++++ 2 files changed, 34 insertions(+) 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-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: {}
