Plugin Nats

Produce ​Produce

yaml
type: "io.kestra.plugin.nats.produce"
yaml
id: nats_produce_single_message
namespace: company.team

tasks:
  - id: produce
    type: io.kestra.plugin.nats.Produce
    url: nats://localhost:4222
    username: nats_user
    password: nats_password
    subject: kestra.publish
    from:
      headers:
        someHeaderKey: someHeaderValue
      data: Some message
yaml
id: nats_produce_two_messages
namespace: company.team

tasks:
  - id: produce
    type: io.kestra.plugin.nats.Produce
    url: nats://localhost:4222
    username: nats_user
    password: nats_password
    subject: kestra.publish
    from:
      - headers:
          someHeaderKey: someHeaderValue
        data: Some message
      - data: Another message
yaml
id: nats_produce_messages_from_file
namespace: company.team

tasks:
  - id: produce
    type: io.kestra.plugin.nats.Produce
    url: nats://localhost:4222
    username: nats_user
    password: nats_password
    subject: kestra.publish
    from: "{{ outputs.some_task_with_output_file.uri }}"
Properties
Min length 1
Min length 1