RabbitMQ

Overview

The RabbitMQ destination allows you to send/stream data to a RabbitMQ routing key. RabbitMQ is one of the most popular open source message brokers.

Each stream will be output a RabbitMQ message with properties. The message properties will be

content_type: set as application/json
headers: message headers, which include:
- stream: the name of stream where the data is coming from
- namespace: namespace if available from the stream
- emitted_at: timestamp the AirbyteRecord was emitted at.

The AirbyteRecord data will be serialized as JSON and set as the RabbitMQ message body.

To use the RabbitMQ destination, you'll need:

A RabbitMQ host and credentials (username/password) to publish messages, if required.
A RabbitMQ routing key.
RabbitMQ exchange is optional. If specified, a binding between exchange and routing key is required.
RabbitMQ port is optional (it defaults to 5672).
RabbitMQ virtual host is also optional.

Expand to review

Version	Date	Pull Request	Subject
0.1.12	2024-07-20	42222	Update dependencies
0.1.11	2024-07-13	41689	Update dependencies
0.1.10	2024-07-10	41279	Update dependencies
0.1.9	2024-07-06	40991	Update dependencies
0.1.8	2024-06-27	40215	Replaced deprecated AirbyteLogger with logging.Logger
0.1.7	2024-06-25	40348	Update dependencies
0.1.6	2024-06-22	40101	Update dependencies
0.1.5	2024-06-06	39300	[autopull] Upgrade base image to v1.2.2
0.1.4	2024-05-21	38532	[autopull] base image + poetry + up_to_date
0.1.3	2024-04-02	#36749	Un-archive connector (again)
0.1.2	2024-03-05	#35838	Un-archive connector
0.1.1	2022-09-09	16528	Marked password field in spec as airbyte_secret
0.1.0	October 29, 2021	#7560	Initial release