Consume
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 *Requiredstring
Min length
1url *Requiredstring
Min length
1batchSize integer
Default
10Minimum
>= 1creds string
deliverPolicy string
Default
AllPossible Values
AllLastNewByStartSequenceByStartTimeLastPerSubjectdurableId string
maxDuration string
maxRecords integerstring
password string
pollDuration string
Default
PT2Ssince string
token string
username string
Outputs
messagesCount integer
uri string
Format
uri