本文介绍如何在云消息队列 RocketMQ 版控制台创建流入源为云消息队列 Kafka 版的消息流入任务。
前提条件
- 您已购买云消息队列 RocketMQ 版实例,且实例处于服务中状态。具体步骤,请参见创建资源。
- 您已购买并部署云消息队列 Kafka 版实例,且实例处于服务中状态。具体步骤,请参见购买和部署实例。
创建消息流入任务
- 登录云消息队列 RocketMQ 版控制台,在左侧导航栏选择。
- 在顶部菜单栏选择地域,如华东1(杭州),然后在消息流入页面中,单击创建任务。
- 在消息流入创建面板,设置任务名称,选择流入类型为消息队列 Kafka版,配置以下信息,然后单击确定。
- 在资源配置区域,设置以下参数。
表 1. 源端消息队列Kafka版参数配置参数 | 说明 | 示例 |
---|
地域 | 默认选择创建消息流入任务时选择的地域且不可更改。 | 华东1(杭州) |
Kafka 实例 | 选择生产消息的源云消息队列 Kafka 版实例。 | alikafka-cn-i7m2hdidh**** |
Topic | 选择生产消息的Topic。 | topic |
Tag(可选) | 配置源实例中用于过滤消息的Tag。 | test |
Group ID | 选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。 | GID_http_1 |
并发配额(消费者数) | 选择源实例的消费者数。 | 1 |
消费位点 | 选择开始消费消息的位点。 | 最新位点 |
网络配置 | 选择路由消息的网络类型。 | 默认网络 |
表 2. 目标端消息队列RocketMQ版参数配置参数 | 说明 | 示例 |
---|
地域 | 接收云消息队列 RocketMQ 版消息的目标实例所在的地域。 | 华东1(杭州) |
版本 | 选择目标端云消息队列 RocketMQ 版实例的版本。 | RocketMQ 4.x |
实例ID | 选择接收云消息队列 RocketMQ 版消息的目标实例。 | MQ_INST_115964845466****_BYEiGXc4 |
Topic | 选择目标实例的Topic。 | test |
- 在数据处理区域,设置消息的过滤、转换、重试和死信。
- 消息过滤
- 无需过滤:默认投递全部事件。
- 自定义配置:使用事件模式匹配特定事件。详细规则,请参见消息过滤。
- 消息转换
- 默认配置:默认将消息内容或相关属性映射到目标端。映射关系,请参见默认配置映射关系。
- 自定义配置:根据自身需求配置自定义参数投递至目标端。
参数 | 说明 | 示例 |
---|
Body | 需要投递的事件的消息内容。配置规则,请参见消息转换。 | 部分事件$.data.body
|
Properties | 需要投递的事件的属性。配置规则,请参见消息转换。 | 部分事件$.data.props
|
Keys | 需要投递的事件的过滤属性。配置规则,请参见消息转换。 | 部分事件$.data.systemProperties.KEYS
|
Tags | 需要投递的事件的过滤属性。配置规则,请参见消息转换。 | 部分事件$.data.systemProperties.TAGS
|
- 重试和死信:配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息,请参见重试和死信。
- 返回消息流入页面,找到创建好的任务,在其右侧操作列,单击启用。
- 在提示对话框,阅读提示信息,然后单击确认。
启用任务后,会有30秒~60秒的延迟时间,您可以在消息流入页面的状态栏查看启动进度。
其他操作
在消息流入页面,找到目标任务,在其右侧操作列,执行其他操作。
- 查看任务详情:单击详情,在消息流入详情页面,查看任务的源端配置、目标端配置及资源信息。
- 编辑任务配置:单击编辑,在消息流入编辑面板,修改资源配置和规则配置。
- 启停任务:单击启用或者停用,然后在提示对话框,单击确认。
- 删除任务:单击删除,然后在提示对话框,单击确认。