功能介绍
RocketMQ（消息队列 RocketMQ 版）是一个分布式消息和流数据平台，具有低延迟、高性能、高可靠性、万亿级容量和灵活的可扩展性。
借助 RocketMQ 连接器，可以实现：向指定 RocketMQ 的主题发送消息，使其他系统可以从 RocketMQ 中获取到消息再消费。
适用场景
数据集成场景中，上游系统（例如电商系统）将记录变更信息通过 RocketMQ 连接器写入 RocketMQ 的指定 Topic 后，其他系统（例如会员系统）监听指定的 RocketMQ 获取到消息并消费消息队列中的数据。
以电商业务中最常见的「订单支付」场景为例：
在订单支付成功后，需要更新订单状态、更新用户积分、通知商家有新订单、更新推荐系统中的用户画像等等。
250px|700px|reset
- 引入 MQ 后，订单支付现在只需要关注它最重要的流程：更新订单状态即可。其他不重要的事情全部交给 MQ 来通知。这便是 MQ 解决的最核心的问题：系统解耦。
- 因为 MQ 的引入，更新用户积分、通知商家、更新用户画像这些步骤全部变成了异步执行，能减少订单支付的整体耗时，提升订单系统的吞吐量。这便是 MQ 的另一个典型应用场景：异步通信。
配置 RocketMQ 连接器
（一）选择 RocketMQ 连接器
点击「三方集成」分组，选择「 RocketMQ 」。添加后，会展开 RocketMQ 连接器的配置面板：
250px|700px|reset
250px|700px|reset
（二）配置连接器
操作与凭证
创建凭证
在节点配置选择凭证时新建凭证，点击后「新建」后将显示新建凭证弹窗：
250px|700px|reset
250px|700px|reset
需要配置的内容如下：
新建后的凭证，将加入到选择凭证下拉框列表内，选择后将展示凭证信息。
基础配置
配置项的说明详见下表：
高级配置
高级配置中可以设置一些触发时的高级选项，均有默认值，若无特殊需求可无需配置。
高级配置详见下表：
输出数据
「输出数据」展示了连接器输出数据的结构和各字段类型及名称：
RocketMQ 连接器会把输出数据会保存至全局变量中：
PSM 鉴权方式下，输出的元信息示例如下：
{
"extraFields": null,
"messageQueue": {
"brokerName": "test_hl4",
"queueId": 0,
"topic": "ipaas_test_lr"
},
"msgId": "0A0C40600037000000007A1C93080001",
"offsetMsgId": "0A9459D80000233D0000747B3298D4B2",
"queueOffset": 7,
"regionId": "DefaultRegion",
"respHeader": {
"errCode": 0,
"errMsg": "OK"
},
"transactionId": ""
}
（三）输出数据使用说明
可以在 NodeJS 节点中引用输出数据的 API 名称进行 JSON 变量的消费，如下图：
250px|700px|reset
