Availability

Airbyte Cloud Airbyte OSS PyAirbyte

Support Level

Archived

RabbitMQ [ARCHIVED]

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.

Sync overview

Output schema

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.

Features

Feature	Supported?(Yes/No)	Notes
Full Refresh Sync	Yes
Incremental - Append Sync	Yes
Incremental - Append + Deduped	No
Namespaces	Yes

Getting started

Requirements

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.

CHANGELOG

Version	Date	Pull Request	Subject
0.1.1	2022-09-09	16528	Marked password field in spec as airbyte_secret
0.1.0	October 29, 2021	#7560	Initial release