专享版事件流-华为云

事件网格 EG-配置专享版事件流作业

配置专享版事件流作业登录事件网格控制台，本章节以配置Kafka事件流作业为例介绍。在左侧导航栏选择“事件流＞专享版事件流作业”，进入“专享版事件流作业”页面。图1 专享版事件流作业页面先停用事件流作业，再单击操作列“修改配置”按钮，进入“基础配置”页面，此处只能修改“作业名称”和“描述”。单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。图2 源数据和目标数据配置表1 源数据目标数据配置参数是否支持修改说明参数是否支持修改配置类型否。实例别名否。区域否。项目否。 Kafka实例否。接入方式是，支持“明文接入”或“密文接入”。安全协议是。当选择明文接入时，安全协议为“PLAINTEXT”。当选择“密文接入”时，安全协议可选择“SASL_SSL”或“SASL_PLAINTEXT”；认证机制可选择“SC RAM -SHA-512”或“PLAIN”。用户名请输入用户名。说明：当接入方式选择“密文接入”时需配置。密码请输入密码。说明：当接入方式选择“密文接入”时需配置。单击“下一步：高级配置”，进入“高级配置”页面。图3 高级配置表2 作业对象配置参数是否支持修改说明参数是否支持修改 Topic匹配类型是，可选择“正则匹配”或“精确匹配”。说明：当选择“正则匹配”时需在下方输入“Topic正则”。当选择“精确匹配”时需选择“Topics”。副本数是。说明：自动创建的Topic副本数，不能超过目标端Kafka的Broker数量。同步消费进度是。说明：开启时表示将消息消费进度同步到目标Kafka。启动偏移量否。压缩算法是，可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。单击“下一步：预检查”，进入“预检查”页面，完成后单击“完成配置”。图4 预检查父主题：专享版事件流作业

事件网格 EG 专享版事件流作业

事件网格 EG-RocketMQ同步RocketMQ:前提条件

前提条件业务有自己的源RocketMQ和目标RocketMQ。源RocketMQ和目标RocketMQ实例支持的版本：4.x、5.x。源RocketMQ和目标RocketMQ实例的规格、Broker数量、存储空间需保持一致。确保vpc、子网、RocketMQ等资源充足。确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。创建VPC和子网的操作指导请参考创建虚拟私有云和子网。

事件网格 EG 创建专享版事件流作业

事件网格 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队列数中未同步的消息数量。

事件网格 EG 创建专享版事件流作业

事件网格 EG-RocketMQ预检查:源端连通性检查

源端连通性检查检查事件流作业所在运行时机器是否能正常连接到源端RocketMQ实例。原因一：无法连接源端RocketMQ实例，请检查网络配置是否正确。解决方案：进入RocketMQ的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端RocketMQ实例网络畅通。原因二：无法连接源端RocketMQ实例，请检查填写的实例信息是否正确。解决方案：进入RocketMQ的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端RocketMQ实例的用户名和密码是否正确。

事件网格 EG 专享版事件流预检查

事件网格 EG-RocketMQ预检查:源端和目标端实例规格检查

源端和目标端实例规格检查检查源端和目标端RocketMQ实例的规格是否匹配。原因：源端和目标端RocketMQ实例的节点数量不一致，请检查源端实例和目标端实例的规格信息。解决方案：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的节点数量是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。检查源端和目标端RocketMQ实例的规格是否匹配。原因：源端和目标端RocketMQ实例的实例类型不一致，请检查源端实例和目标端实例的规格信息。解决方案：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的类型是否一致，要求都是集群或者都是单机，若不一致，请修改源端或者目标端实例，使二者保持一致。

事件网格 EG 专享版事件流预检查

事件网格 EG-RocketMQ预检查:源端和目标端实例版本检查

源端和目标端实例版本检查检查源端和目标端RocketMQ实例的版本是否符合要求，当前要求RocketMQ实例版本在5.x和4.8.0中，版本不在匹配名单中则提示告警。原因一：源端RocketMQ实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。检查源端和目标端RocketMQ实例的版本是否一致，版本不一致则提示告警。原因：源端实例和目标端实例的版本不一致，请检查源端实例和目标端实例的版本。解决方式：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的版本是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。

事件网格 EG 专享版事件流预检查

事件网格 EG-RocketMQ预检查:目标端连通性检查

目标端连通性检查检查事件流作业所在运行时机器是否能正常连接到目标端RocketMQ实例。原因一：无法连接目标端RocketMQ实例，请检查网络配置是否正确。解决方案：进入RocketMQ的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端RocketMQ实例网络畅通。原因二：无法连接目标端RocketMQ实例，请检查填写的实例信息是否正确。解决方案：进入RocketMQ的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端RocketMQ实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的目标端RocketMQ实例的用户名和密码是否正确。

事件网格 EG 专享版事件流预检查

事件网格 EG-专享版事件流概述:功能简介

功能简介引导式同步使用EG专享版事件流秒变同步专家。场景化选择预设使用场景，让数据同步更少配置、更简单。网络与安全支持SSL等加密和认证机制，让数据同步更安全。多种同步模式支持对象选择、全量+增量同步和多种压缩模式，满足不同同步诉求。预检查预检查支持提前识别同步是否满足成功条件，提供失败原因、失败详情和处理建议信息。用户可以根据失败信息和处理建议的指导，调整环境，以确保同步成功。同步监控全面可观测/可维护性，支持流控，同步情况，尽在掌握之中。

事件网格 EG 专享版事件流

云服务器内容精选

专享版事件流

7*24

备案

专业服务

退订

建议反馈

售前咨询热线