移动云RocketMQ版

前提条件

• 已在移动云购买RocketMQ实例。
• 当源端为移动云RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。

创建移动云 RocketMQ版事件源

1. 登录事件网格控制台。
2. 在左侧导航栏选择“事件流 > Serverless版事件流”，进入“Serverless版事件流”页面。
3. 单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。
4. 单击“事件源”，弹出“配置事件源”对话框。
   图1 配置事件源
   

5. 参考表1，填写事件源的配置信息。

   表1 移动云 RocketMQ版参数说明

   参数名称	说明
   事件提供方	选择移动云 RocketMQ版。
   实例ID	请输入实例ID。
   Group ID	请输入Group ID。
   Topic	请输入Topic。
   Tag	请输入Tag。 说明： 表示订阅指定Topic下的Tags。 * 表示订阅所有消息。 TagA || TagB || TagC 表示订阅TagA或TagB或TagC的消息。
   开启保存消息轨迹	请选择是否开启保存消息轨迹。
   启用鉴权认证	请选择是否启用鉴权认证。
   Access Key（启用鉴权认证）	请输入Access Key。
   Secret Key（启用鉴权认证）	请输入Secret Key。
   订阅方式	请选择集群或广播。
   接入点类型	请选择公网或私网。
   地址	请输入地址。
   客户端SDK	请输入客户端SDK上传到OBS的地址。 说明： 客户端SDK上传到OBS的地址获取方式可参考常见问题。
   消费超时时间（毫秒）	请输入1000到900000之间的整数。
   消息类型	请选择普通消息。
   消费线程数	请输入20到64之间的整数。
   批量消费最大消息数	请输入1到32之间的整数。
   批量消费最大等待时长（秒）	请输入0到450之间的整数。

6. 单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。
   图2 规则配置
   

7. 单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。
   

   事件源配置为移动云RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。

8. 当事件源和事件目标都配置完成后，单击“保存”，完成事件流的创建。
   

   • MQ采集函数首次启动分钟级后生效。
   • 广播模式下不支持失败重试，即消费失败后，失败消息不再重试，消费者继续消费新的消息。
   • 发送到目标端失败时，将利用RocketMQ本身的重试能力进行重试，目标端需支持处理重复事件，达到重试上限时，源端消息进入RocketMQ对应topic的死信队列，EG事件不再投递。