事件网格 EG-RocketMQ同步RocketMQ:操作步骤
操作步骤
- 登录事件网格控制台。
- 在左侧导航栏选择“事件流>专享版事件流作业”,进入“专享版事件流作业”页面。
图1 专享版事件流作业页面
- 右上角单击“创建作业”,进入“基础配置”。
- 配置“基本配置”信息。
图2 基本配置
表1 作业基本配置参数说明 参数
说明
集群
选择已创建的集群,如未创建,请参见专享版事件流集群。
作业名称
请输入作业名称。
场景类型
当前默认为同步。
描述
请输入对本作业的描述。
- 单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。
图3 源数据和目标数据配置
表2 源数据和目标数据配置参数说明 参数
说明
配置类型
默认为“Rocketmq实例”。
说明:配置类型根据实例类型变更。
实例别名
请输入实例别名。
说明:用于标识源端和目标端实例,建议同一个源端或目标端实例只设置一个别名。
区域
请选择资源所在区域。
项目
请选择项目。
Rocketmq实例
请选择Rocketmq实例。
用户名
请输入用户名。
密钥
请输入密钥。
- 单击“下一步:高级配置”,进入“高级配置”页面。
图4 高级配置
RocketMQ同步事件流当前仅支持同步普通消息和顺序消息。若您配置Topic的消息类型是其它类型时,则该消息类型的Topic消息将不会被同步。
表3 作业对象配置参数说明 参数
说明
Topic匹配类型
选择“正则匹配”或“精确匹配”。
说明:- 当选择“正则匹配”时需在下方输入“Topic正则”。示例:.* 表示匹配所有Topic,topic.* 表示匹配所有以topic为前缀的Topic。
- 当选择“精确匹配”时需选择“Topics”。
同步消费进度
请选择是否打开。
说明:开启时表示将消息消费进度同步到目标Rocketmq。
启动偏移量
请选择为“最早”、“最新”或“自定义”。
压缩算法
请选择压缩算法为“none”、“lz4”、“zstd”或“zlib”。
- 单击“下一步:预检查”,进入“预检查”页面,完成后单击“完成配置”。
图5 预检查
- 返回专享版事件流作业列表,单击刚才创建的事件流名称,进入“基本信息”页面,选择“作业管理”,可以查看“同步进展详情”。
图6 Rocketmq事件流同步进展详情
表4 参数说明 参数名称
说明
Topic名称
创建RocketMQ实例时的Topic。
队列数
创建Topic时设置的队列个数。
待同步数
当前Topic队列数中未同步的消息数量。
- RocketMQ是什么_RocketMQ介绍_分布式消息服务RocketMQ版
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- 事件网格是什么_事件发送流程_事件网格消息中间件
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- 华为云事件网格_事件源_事件目标
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- RocketMQ主要应用场景有哪些_分布式消息中间件_分布式消息RocketMQ-华为云
- 分布式消息服务优势_分布式消息服务_消息队列-华为云
- 分布式消息队列是什么_分布式消息队列好处_消息队列-华为云