Airbyte source connector for getting messages from AMQP into Airbyte
741
An Airbyte source connector for consuming messages from AMQP brokers (RabbitMQ, LavinMQ, etc.). Written in Go.
Enables streaming AMQP messages into any Airbyte-supported destination such as databases, data warehouses, or data lakes.
To add as a custom connector in Airbyte:
cloudamqp/airbyte-source-amqplatest (or a specific version like 1.0.0)| Field | Required | Description |
|---|---|---|
amqp_url | Yes | AMQP connection URL (e.g., amqps://user:pass@host:5671/vhost) |
exchange | Yes | Name of the AMQP exchange to consume from |
queue_name | Yes | Name of the queue to create and bind to the exchange |
binding_key | No | Routing key for queue binding (empty for fanout/all messages) |
stream_name | Yes | Name of the Airbyte stream for the destination |
Report issues at https://github.com/cloudamqp/airbyte-connector/issues
For help, reach out to [email protected]
Content type
Image
Digest
sha256:7a85fdb1a…
Size
5.9 MB
Last updated
8 months ago
docker pull cloudamqp/airbyte-source-amqp