检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更
Kafka同步Kafka 当前仅支持华南-广州。 前提条件 业务有自己的源Kafka和目标Kafka。 源Kafka和目标Kafka实例支持的版本：目前支持2.7及以上，后续支持版本会持续更新。 源Kafka和目标Kafka实例的规格、存储空间需保持一致。 确保vpc、子网、kafka等资源充足。
检查事件流作业所在运行时机器是否能正常连接到目标端Kafka实例。 原因一：无法连接目标端Kafka实例，请检查网络配置是否正确。 解决方案： 进入Kafka的控制台页面，检查目标端实例状态是否正常。 检查事件流集群创建页面中配置的vpc和子网是否与目标端Kafka实例网络畅通。 原因二：无法连接目标端Ka
“更多配置”中配置如下参数： Kafka SASL_SSL：开启 kafka安全协议：SASL_SSL SASL PLAIN 机制：开启 用户名：kafka-name 密码：填写密码 默认密码：确认密码 单击“立即购买”，完成Kafka实例的创建。 创建Topic 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。
选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接，如何创建请参见目标连接。 Topic 选择Topic。先选目标连接以加载Topic选项。 消息Key配置 关闭 不启用消息Key。 开启 变量：从CloudEvents标准事件中获取变量值，将变量值作为Key值。
如何获取分布式消息服务Kafka实例的SASL证书地址？ 用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。
分布式消息服务Kafka版 本章节介绍在创建事件流时，如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例，详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口，详情
单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 创建目标连接成功后，不支持修改Kafka实例参数。 参考Kafka目标连接参数说明，填写目标连接的配置信息。 表2 Kafka目标连接参数说明
目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图2 分布式消息服务 Kafka版 表2 分布式消息服务 Kafka版参数说明 参数名称 说明 目标连接 选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接。 Topic 选择Topic。先选目标连接以加载Topic选项。
subnet_id 是 String 待连接的子网ID 最大长度：128 type 否 String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例 枚举值： WEBHOOK KAFKA kafka_detail 否 KafkaConnectionDetail
String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor flavor object 规格 type String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例
String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor flavor object 规格 type String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例
取、过滤及转换，并路由至事件目标。源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版，无需定义事件网格。详情请参见事件流概述。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
基于Serverless版事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的Serverless版事件流功能实现分布式消息服务Kafka版实例间的数据同步。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor flavor object 规格 type String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例
支持地域 支持在分布式消息服务Kafka版之间创建事件流的地域有：华东-上海一、华东-上海二、华北-北京四、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
实施步骤 创建OBS桶 购买Kafka实例 创建Kafka目标连接 创建事件订阅 发送OBS事件 查看事件消息 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
00 分布式消息服务 Kafka版 购买一个Kafka实例，按需计费。 1 例如：kafka.2u4g.cluster 4.35元/小时 事件网格EventGrid 创建一个事件订阅，事件源为OBS应用事件源，事件目标为分布式消息服务Kafka版。 创建一个目标连接，类型为“分布式消息服务
基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 方案概述 资源和成本规划 操作流程 实施步骤
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
