Produce

yaml

type: "io.kestra.plugin.nats.Produce"

Produce messages to a NATS subject on a NATS server.

Examples

Produce a single message to kestra.publish subject, using user password authentication.

yaml

id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from:
  headers:
    someHeaderKey: someHeaderValue
  data: Some message

Produce 2 messages to kestra.publish subject, using user password authentication.

yaml

id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from:
  - headers:
      someHeaderKey: someHeaderValue
    data: Some message
  - data: Another message

Produce messages (1 / row) from an internal storage file to kestra.publish subject, using user password authentication.

yaml

id: "produce"
type: "io.kestra.plugin.nats.Produce"
url: nats://localhost:4222
username: nats_user
password: nats_passwd
subject: kestra.publish
from: {{outputs.someTaskWithOutputFile.uri}}