Consume Consume
Consume Certified

yaml
type: "io.kestra.plugin.amqp.Consume"
yaml
id: amqp_consume
namespace: company.team

tasks:
  - id: consume
    type: io.kestra.plugin.amqp.Consume
    host: localhost
    port: 5672
    username: guest
    password: guest
    virtualHost: /my_vhost
    queue: kestramqp.queue
    maxRecords: 1000
Properties
DefaultSTRING
Possible Values
STRINGJSON
DefaultKestra
Formatduration
Default5672
Default/
Formaturi

More Plugins in this Category

Apache Pulsar
Apache Pulsar

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

Messaging

5 Tasks

1 Blueprints

AWS
AWS

AWS plugin for Kestra

AlertingCloudMessagingStorageDatabaseScriptToolTransformation

45 Tasks

22 Blueprints

NATS
NATS

Tasks that publish, subscribe, and work with NATS messaging.

Messaging

9 Tasks
OVERVIEW
Versions
1.1.1
Latest
December 22, 2025 Release Notes Min. Compatible Kestra Version: 1.0.0
Previous Versions
1.1.0October 31, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.2October 31, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.1October 27, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.0September 8, 2025 Min. Compatible Kestra Version: 1.0.0

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Messaging
Links & Resources
GitHub