Rabbitmq

Rabbitmq sink connector

Description​

Used to write data to Rabbitmq.

Key features​

Options​

name
type
required
default value

host

string

yes

-

port

int

yes

-

virtual_host

string

yes

-

username

string

yes

-

password

string

yes

-

queue_name

string

yes

-

url

string

no

-

network_recovery_interval

int

no

-

topology_recovery_enabled

boolean

no

-

automatic_recovery_enabled

boolean

no

-

use_correlation_id

boolean

no

false

connection_timeout

int

no

-

rabbitmq.config

map

no

-

common-options

no

-

host [string]​

the default host to use for connections

port [int]​

the default port to use for connections

virtual_host [string]​

virtual host – the virtual host to use when connecting to the broker

username [string]​

the AMQP user name to use when connecting to the broker

password [string]​

the password to use when connecting to the broker

url [string]​

convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host

queue_name [string]​

the queue to write the message to

schema [Config]​

fields [Config]​

the schema fields of upstream data.

network_recovery_interval [int]​

how long will automatic recovery wait before attempting to reconnect, in ms

topology_recovery_enabled [boolean]​

if true, enables topology recovery

automatic_recovery_enabled [boolean]​

if true, enables connection recovery

use_correlation_id [boolean]​

whether the messages received are supplied with a unique id to deduplicate messages (in case of failed acknowledgments).

connection_timeout [int]​

connection TCP establishment timeout in milliseconds; zero for infinite

rabbitmq.config [map]​

In addition to the above parameters that must be specified by the RabbitMQ client, the user can also specify multiple non-mandatory parameters for the client, covering all the parameters specified in the official RabbitMQ document.

common options​

Sink plugin common parameters, please refer to Sink Common Options for details

Example​

simple:

sink {
      RabbitMQ {
          host = "rabbitmq-e2e"
          port = 5672
          virtual_host = "/"
          username = "guest"
          password = "guest"
          queue_name = "test1"
          rabbitmq.config = {
            requested-heartbeat = 10
            connection-timeout = 10
          }
      }
}

Last updated