Consume

yaml
type: "io.kestra.plugin.nats.core.Consume"

Examples

yaml
id: nats_consume_messages
namespace: company.team

tasks:
  - id: consume
    type: io.kestra.plugin.nats.core.Consume
    url: nats://localhost:4222
    username: nats_user
    password: nats_password
    subject: kestra.>
    durableId: someDurableId
    pollDuration: PT5S

Properties

subject*string

Min length1

url*string

Min length1

batchSizeinteger

Default10

Minimum>= 1

credsstring

deliverPolicystring

DefaultAll

Possible Values

AllLastNewByStartSequenceByStartTimeLastPerSubject

durableIdstring

maxDurationstring

Formatduration

maxRecordsintegerstring

passwordstring

pollDurationstring

DefaultPT2S

Formatduration

sincestring

tokenstring

usernamestring

Outputs

messagesCountinteger

uristring

Formaturi