RabbitMQ connector

• Starter
• Business
• Enterprise
• On-Premise
• Add-on

About RabbitMQ

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 stream messages from the queue to various destinations.
• to implement a log-based CDC with a message queue.
  • Stream CDC events to the message queue.
  • Stream CDC events from the message queue to any destination.

Create a Connection

Step 1. In the Connections window, click +, and type in rabbit.

Step 2. Select RabbitMQ.

Step 3. Enter the Connection parameters.

Connection parameters

• URL: the connection URL in the format amqps://host:port. For example for RabbitMQ hosted on AWS: amqps://a-d5c415b0-d5e1-4ee6-b8f1-e09d0106f719-1.mq.us-east-1.amazonaws.com:5671.
• 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.