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

batchSize integer

Default10

Minimum>= 1

creds string

deliverPolicy string

DefaultAll

Possible Values

AllLastNewByStartSequenceByStartTimeLastPerSubject

durableId string

maxDuration string

maxRecords integerstring

password string

pollDuration string

DefaultPT2S

since string

token string

username string

Outputs

messagesCount integer

uri string

Formaturi

Apache Pulsar

Tasks that publish, consume, and trigger workflows with Apache Pulsar.

Messaging

AMQP

Tasks that connect to RabbitMQ brokers to declare exchanges and queues, bind routing keys, publish messages, and consume them via tasks or triggers (batch or real time).

Messaging

AWS

AWS plugin for Kestra

AlertingCloudMessagingStorageDatabaseScriptToolTransformation

Consume

More Plugins in this Category

Apache Pulsar

AMQP

AWS

1.1.2