云服务器内容精选

华为云首页用户手册

基于事件流实现Kafka实例之间的数据同步

事件网格 EG-实施及验证:源端配置操作步骤

源端配置操作步骤登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”。在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。配置Kafka事件源。单击“事件源”，右侧弹出“事件源”弹窗。事件提供方选择“分布式消息服务 Kafka版”。设置事件源参数。图1 事件源-Kafka 表1 配置参数说明参数名称说明实例选择Kafka实例。 Topic 选择Topic。消费组输入消费组。并发数输入并发数，输入值范围1~1000。建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。消费点位选择消费点位。最新点位：将会从消息队列的最新消息开始消费。最早点位：将会从消息队列的最早消息开始消费。 SASL认证机制当Kafka实例开启SASL SSL时可见，选择SASL认证机制。 PLAIN：一种简单的用户名密码校验机制。 SC RAM -SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。 SASL证书地址当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。说明：必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M；压缩包里证书的名称必须是固定的：client.jks。 SASL证书密钥当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。用户名当Kafka实例开启SASL SSL时可见，输入实例用户名。用户密码当Kafka实例开启SASL SSL时可见，输入实例用户密码。单击“保存”，完成配置事件源。

事件网格 EG 基于事件流实现Kafka实例之间的数据同步
事件网格 EG-实施及验证:目标端配置操作步骤

目标端配置操作步骤登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”。配置事件目标。单击“事件目标”，右侧弹出“事件目标”弹窗。目标服务选择“分布式消息服务 Kafka版”。设置事件目标参数。图2 分布式消息服务 Kafka版表2 分布式消息服务 Kafka版参数说明参数名称说明目标连接选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接。 Topic 选择Topic。先选目标连接以加载Topic选项。消息Key配置关闭不启用消息Key。开启变量：从CloudEvents标准事件中获取变量值，将变量值作为Key值。常量：将指定的常量作为key值。若选择常量，所有消息将发送至同一分区。规则配置类型变量：data.value 如果需要了解更多转换类型的信息，请参考事件内容转换。消息推送批量推送配置是否开启批量推送，批量推送可帮您批量聚合多个事件。批量推送条数推送间隔开启批量推送可见，每次批量推送的最大聚合条数，默认值100，输入值范围1~10000。开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。事件目标kafka不支持自定义证书。表3 批量推送示例批量推送条数推送间隔实际发送效果 100条 1s 每隔1s批量推送100条消息 200条 5s 每隔5s批量推送500条消息配置完成后，单击“确定”。单击“事件流列表”操作列的“启用”，待状态列显示为“运行中”则代表整个链路创建成功。

事件网格 EG 基于事件流实现Kafka实例之间的数据同步