Consume
yaml
type: "io.kestra.plugin.nats.consume"Examples
yaml
id: nats_consume_messages
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.nats.Consume
url: nats://localhost:4222
username: nats_user
password: nats_password
subject: kestra.>
durableId: someDurableId
pollDuration: PT5S
Properties
subject *Requiredstring
Min length
1url *Requiredstring
Min length
1batchSize integer
Default
10 Minimum
>= 1creds string
deliverPolicy string
Default
All Possible Values
AllLastNewByStartSequenceByStartTimeLastPerSubjectdurableId string
maxDuration string
Format
durationmaxRecords integerstring
password string
pollDuration string
Default
PT2S Format
durationsince string
token string
username string
Outputs
messagesCount integer
uri string
Format
uri