Rabbitmq
Rabbitmq sink connector
Description​
Used to write data to Rabbitmq.
Key features​
Options​
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