Skip to content

RabbitMQ Sink 组件使用说明

组件说明

RabbitMQ Sink 用于将数据写入 RocketMQ,没有 Source 那样的并行度限制,也无须为精确一次语义(Exactly-Once)做特殊配置。

配置项说明

配置名称数据类型是否必填默认值描述
节点名称StringRabbitMQ当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
节点编码String自动生成当前创建的节点编码,以此标识此组件,由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
选择数据源String-从下拉选项中选择列出的当前项目已经关联的数据源。
队列名称String-队列名称。
持久化Boolean-是否数据持久化。
是:队列重启后保留。
否:服务器重启后删除。
是否独占Boolean-是:仅当前连接可用,断开即删。
自动删除Boolean-最后消费者取消订阅时自动删除。
自动恢复Boolean-当客户端由于网络问题、代理故障或其他问题而失去与代理的连接时,客户端将重新连接。
拓扑恢复Boolean-一旦连接重新建立,将自动恢复消息拓扑。
启用 correlation_id 进行消息追踪Boolean-是否启用 correlation_id 进行消息追踪。
网络恢复间隔Int5000动态发现主题和分区的时间间隔。单位:毫秒。
TCP连接超时时间Int60000TCP 建连超时(毫秒,0表示无限)。
可选参数-其他参数,用户可以根据需求进行配置。

FAQ

Q1:数据结构都包含什么,都支持什么类型?

  • 包括字段名称和字段类型:
  • 字段类型:
    • 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