RabbitMQ is one of the most popular open-source message brokers. It is lightweight, easy to deploy on-premises and in the cloud, and supports multiple messaging protocols. Read more about RabbitMQ.
When to use this connector
- to read messages from and write messages to a given RabbitMQ queue.
- to implement a log-based CDC with a message queue.
Create a Connection
Step 1. In the
Connections window, click
+, and type in
Step 2. Select
Step 3. Enter the Connection parameters.
URL: the connection URL in the format
amqps://host:port. For example for RabbitMQ hosted on AWS:
Queue name: the optional RabbitMQ queue name.
User: the user name.
Password: the password.
Max number of records to read: the total maximum number of records to read from the queue. Set it to a reasonable number to allow the system to process records in micro-batches. If nothing is entered the system will read records from the queue until there are no more records.
Number of retries before stop polling: the number of retries before stop polling if poll returns no records.
Retry N minutes before stop pollingDelay between retries: the number of minutes to retry before stop polling if the poll returns no records.
Delay between retries (ms): the delay between retries. Set it to avoid exceeding the limit on frequency.
Durable: this property is used when creating a new queue. If the property is enabled the queue will survive a broker restart.
Exclusive: this property is used when creating a new queue. If the property is enabled the queue can be used by only one connection and will be deleted when that connection closes.
Auto Delete: this property is used when creating a new queue. If the property is enabled the queue that has had at least one consumer is deleted when the last consumer unsubscribed.
Other parameters:additional configuration options for the RabbitMQ connection.