Skip to main content

RabbitMQ Connector

Source​

The RabbitMQ Source connector is used for receiving messages from a RabbitMQ cluster and writing messages to Pulsar topics.

Source Configuration Options​

NameRequiredDefaultDescription
connectionNametruenullA new broker connection name.
amqUritruenullAn AMQP URI: host, port, username, password and virtual host.
queueNametruenullRabbitMQ queue name.