Skip to main content

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.

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

FeatureSupported?(Yes/No)Notes
Full Refresh SyncYes
Incremental - Append SyncYes
Incremental - Deduped HistoryNoAs this connector does not support dbt, we don't support this sync mode on this destination.
NamespacesYes

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

VersionDatePull RequestSubject
0.1.0October 29, 2021#7560Initial release