同步操作将从 Apache SeaTunnel/SeaTunnel 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
Rabbitmq sink connector
Used to write data to Rabbitmq.
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 | - |
the default host to use for connections
the default port to use for connections
virtual host – the virtual host to use when connecting to the broker
the AMQP user name to use when connecting to the broker
the password to use when connecting to the broker
convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host
the queue to write the message to
the schema fields of upstream data.
how long will automatic recovery wait before attempting to reconnect, in ms
if true, enables topology recovery
if true, enables connection recovery
whether the messages received are supplied with a unique id to deduplicate messages (in case of failed acknowledgments).
connection TCP establishment timeout in milliseconds; zero for infinite
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.
Sink plugin common parameters, please refer to Sink Common Options for details
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
}
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。