Consume

Consume messages from an AMQP queue.

Requires maxDuration or maxRecords.

yaml
type: "io.kestra.plugin.amqp.Consume"

yaml
id: amqp_consume
namespace: company.team

tasks:
  - id: consume
    type: io.kestra.plugin.amqp.Consume
    url: amqp://guest:guest@localhost:5672/my_vhost
    queue: kestramqp.queue
    maxRecords: 1000

Dynamic YES

Default Kestra

A client-generated consumer tag to establish context.

Dynamic YES

The queue to pull messages from.

Dynamic YES

Default STRING

Possible Values

STRINGJSON

Serializer / Deserializer used for the message.

Dynamic YES

The broker host.

Dynamic YES

Format duration

The maximum duration to wait for new rows.

It's not an hard limit and is evaluated every second.

Dynamic YES

The broker password.

Dynamic YES

The broker port.

Dynamic YES

The broker username.

Dynamic YES

The broker virtual host.

Number of rows consumed.

Format uri

File URI containing consumed messages.

​Consume

Consume