事件网格 EG-RocketMQ同步RocketMQ:操作步骤

时间:2024-12-27 15:01:47

操作步骤

  1. 登录事件网格控制台
  2. 在左侧导航栏选择“事件流>专享版事件流作业”,进入“专享版事件流作业”页面。

    图1 专享版事件流作业页面

  3. 右上角单击“创建作业”,进入“基础配置”。
  4. 配置“基本配置”信息。

    图2 基本配置
    表1 作业基本配置参数说明

    参数

    说明

    集群

    选择已创建的集群,如未创建,请参见专享版事件流集群

    作业名称

    请输入作业名称。

    场景类型

    当前默认为同步。

    描述

    请输入对本作业的描述。

  5. 单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。

    图3 源数据和目标数据配置
    表2 源数据和目标数据配置参数说明

    参数

    说明

    配置类型

    默认为“Rocketmq实例”。

    说明:

    配置类型根据实例类型变更。

    实例别名

    请输入实例别名。

    说明:

    用于标识源端和目标端实例,建议同一个源端或目标端实例只设置一个别名。

    区域

    请选择资源所在区域。

    项目

    请选择项目。

    Rocketmq实例

    请选择Rocketmq实例。

    用户名

    请输入用户名。

    密钥

    请输入密钥。

  6. 单击“下一步:高级配置”,进入“高级配置”页面。

    图4 高级配置

    RocketMQ同步事件流当前仅支持同步普通消息和顺序消息。若您配置Topic的消息类型是其它类型时,则该消息类型的Topic消息将不会被同步。

    表3 作业对象配置参数说明

    参数

    说明

    Topic匹配类型

    选择“正则匹配”或“精确匹配”。

    说明:
    • 当选择“正则匹配”时需在下方输入“Topic正则”。示例:.* 表示匹配所有Topic,topic.* 表示匹配所有以topic为前缀的Topic。
    • 当选择“精确匹配”时需选择“Topics”。

    同步消费进度

    请选择是否打开。

    说明:

    开启时表示将消息消费进度同步到目标Rocketmq。

    启动偏移量

    请选择为“最早”、“最新”或“自定义”。

    压缩算法

    请选择压缩算法为“none”、“lz4”、“zstd”或“zlib”。

  7. 单击“下一步:预检查”,进入“预检查”页面,完成后单击“完成配置”。

    图5 预检查

  8. 返回专享版事件流作业列表,单击刚才创建的事件流名称,进入“基本信息”页面,选择“作业管理”,可以查看“同步进展详情”。

    图6 Rocketmq事件流同步进展详情
    表4 参数说明

    参数名称

    说明

    Topic名称

    创建RocketMQ实例时的Topic。

    队列数

    创建Topic时设置的队列个数。

    待同步数

    当前Topic队列数中未同步的消息数量。

support.huaweicloud.com/usermanual-eg/eg-ug-091.html