云服务器内容精选

华为云首页用户手册

创建专业版事件流作业

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

操作步骤登录事件网格控制台。在左侧导航栏选择“事件流＞专业版事件流作业”，进入“专业版事件流作业”页面。右上角单击“创建作业”，进入“基础配置”。配置“基本配置”信息，以下内容将以非白名单账号举例介绍。表1 作业基本配置参数说明参数说明集群选择已创建的集群，如未创建，请参见专业版事件流集群。作业名称请输入作业名称。场景类型可选“同步”或“迁移”。同步：实现数据源之间的数据实时同步，支持正向和反向的长期单向数据同步。迁移：适用于业务割接期数据的整体搬迁上云，只支持短期单向同步。描述请输入对本作业的描述。单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。图1 源数据和目标数据配置表2 源数据和目标数据配置参数说明参数说明配置类型默认为“Kafka实例”。说明：配置类型根据实例类型变更。实例别名请输入实例别名。用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。区域请选择资源所在区域。项目请选择项目。 Kafka实例请选择Kafka实例。接入方式支持“明文接入”或“密文接入”。安全协议当选择明文接入时，安全协议为“PLAINTEXT”。当选择“密文接入”时，安全协议可选择“SASL_SSL”或“SASL_PLAINTEXT”；认证机制可选择“SC RAM -SHA-512”或“PLAIN”。用户名请输入用户名。当接入方式选择“密文接入”时需配置。密码请输入密码。当接入方式选择“密文接入”时需配置。单击“下一步：高级配置”，进入“高级配置”页面。图2 高级配置表3 作业对象配置参数说明参数说明 Topic匹配类型选择“正则匹配”或“精确匹配”。说明：当选择“正则匹配”时需在下方输入“Topic正则”。示例：.* 表示匹配所有Topic，topic.* 表示匹配所有以topic为前缀的Topic。当选择“精确匹配”时需选择“Topics”。副本数请配置副本数。自动创建的Topic副本数，不能超过目标端Kafka的Broker数量。同步消费进度请选择是否打开。开启时表示将消息消费进度同步到目标Kafka。启动偏移量请选择为“最早”或“最新”。压缩算法请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。单击“下一步：预检查”，进入“预检查”页面，完成后单击“完成配置”。图3 预检查返回专业版事件流作业列表，单击刚才创建的事件流名称，进入“基本信息”页面，选择“作业管理”，可以查看“同步进展详情”。图4 Kafka事件流同步进展详情表4 参数说明参数名称说明 Topic名称创建Kafka实例时的Topic。分区数创建Topic时设置的分区数，分区数越大消费的并发度越大。待同步数当前Topic分区数中未同步的消息数量。同步速率：当前作业同步消息时的速率，单击“限流”可跳转至源端Kafka实例的“流控列表”页面，用户可通过配置流控进而实现限流目的。

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