# RabbitMQ Sink 组件使用说明
# 组件说明
RabbitMQ Sink 用于将数据写入 RocketMQ,没有 Source 那样的并行度限制,也无须为精确一次语义(Exactly-Once)做特殊配置。
# 配置项说明
| 配置名称 | 数据类型 | 是否必填 | 默认值 | 描述 |
|---|---|---|---|---|
| 节点名称 | String | 是 | RabbitMQ | 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。 |
| 节点编码 | String | 是 | 自动生成 | 当前创建的节点编码,以此标识此组件,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。 |
| 选择数据源 | String | 是 | - | 从下拉选项中选择列出的当前项目已经关联的数据源。 |
| 队列名称 | String | 是 | - | 队列名称。 |
| 持久化 | Boolean | 是 | - | 是否数据持久化。 是:队列重启后保留。 否:服务器重启后删除。 |
| 是否独占 | Boolean | 否 | - | 是:仅当前连接可用,断开即删。 |
| 自动删除 | Boolean | 否 | - | 最后消费者取消订阅时自动删除。 |
| 自动恢复 | Boolean | 否 | - | 当客户端由于网络问题、代理故障或其他问题而失去与代理的连接时,客户端将重新连接。 |
| 拓扑恢复 | Boolean | 否 | - | 一旦连接重新建立,将自动恢复消息拓扑。 |
| 启用 correlation_id 进行消息追踪 | Boolean | 否 | - | 是否启用 correlation_id 进行消息追踪。 |
| 网络恢复间隔 | Int | 否 | 5000 | 动态发现主题和分区的时间间隔。单位:毫秒。 |
| TCP连接超时时间 | Int | 否 | 60000 | TCP 建连超时(毫秒,0表示无限)。 |
| 可选参数 | 否 | - | 其他参数,用户可以根据需求进行配置。 |
# FAQ
- 包括字段名称和字段类型:
- 字段类型:
- string
- boolean
- tinyint
- smallint
- int
- bigint
- float
- double
- decimal
- bytes
- date
- timestamp
- map (map<string, int>,map<string, string>,map<string, boolean>,map<string, tinyint>,map<string, smallint>,map<string, bigint>,map<string, float>,map<string, double>,map<string, decimal>,map<string, date>,map<string, time>,map<string, timestamp>,map<string, null>,map<string, array>,map<string, map>
)
- array
- string