检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
方案概述 本文介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示： 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
查看事件消息 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
前提条件 进行本实践操作需要提前完成的事项： 已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组。 实践流程 创建事件订阅和事件路由流程如下图所示： 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
8 请下载1.4.0版本的 Java SDK 将jar包打包成zip文件 参考创建桶，创建一个OBS桶，桶的区域与EG服务的区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 参考上传文件，在桶的根目录下上传打包的ZIP文件。 在OBS中单击上传的对象，可以复制链接地址，此地址即为客户端SDK地址。
购买Kafka实例 购买实例 登录分布式消息服务Kafka版控制台，单击页面右上方的“购买Kafka实例”。 配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。 计费模式：按需计费 区域：与事件网格所在区域保持一致 项目：选择默认项目 可用区：根据默认项配置
权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建Kafka目标连接参数的详细介绍，请参考创建目标连接。 类型：选择“分布式消息服务 Kafka版” 名称：kafka-connect 实例：选择“eg-kafka” SASL_SSL 认证机制：SCRAM-SHA-512
登录分布式消息服务Kafka控制台。 在分布式消息服务Kafka专享版页面，单击Kafka实例。 在实例“基本信息>连接信息”页面，单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑，名字为“kafka-certs.zip”的文件。 参考创建桶，创建一个OBS桶，桶的区域与
400 EGS.00516012 下载OBS文件失败。 下载OBS文件失败。 请联系管理员 400 EGS.00516013 文件上传OBS失败。 文件上传OBS失败。 请联系管理员 400 EGS.00516015 OBS桶创建失败。 OBS桶创建失败。 请联系管理员 400 EGS
import java.net.URI; import java.time.LocalDateTime; import java.time.OffsetDateTime; import java.time.format.DateTimeFormatter; import java.util
设备接入服务 IoTDA 分布式消息服务 DMS 知识图谱 KG IoT边缘 IoTEdge 云日志服务 LTS 编译构建 CloudBuild 对象存储迁移服务 OMS 云备份服务 CBR 消息&短信服务 MSGSMS 弹性公网IP EIP 云审计服务 CTS 云搜索服务 CSS
入门实践 实践 描述 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 基于事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版
订阅方式 请选择集群或广播。 接入点类型 请选择公网或私网。 地址 请输入地址。 客户端SDK 请输入客户端SDK上传到OBS的地址。 说明： 客户端SDK上传到OBS的地址获取方式可参考常见问题。 消费超时时间（毫秒） 请输入1000到900000之间的整数。 消息类型 请选择普通消息。
事件 事件是符合特定规范的数据。事件源发布到事件网格的事件必须符合CloudEvents规范。 事件网格支持的事件如下。 华为云服务事件：华为云服务事件源产生的事件。 自定义事件：您自定义的事件源接入事件网格产生的事件。您需要自行使用SDK接入事件网格。 事件示例 事件源发布到事件网格的事件示例如下：
配置事件源 选择事件源提供方。 华为云：华为云服务事件源作为事件源提供方。 自定义：您自定义的事件源作为事件源提供方。 设置事件源参数。 当提供方为“华为云”时，设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。
事件目标 路由到函数工作流 路由到分布式消息服务Kafka版 路由到对象存储服务OBS 父主题： 事件流
API 事件订阅管理 事件通道管理 事件管理 事件源管理 事件目标分类管理 事件模型管理 目标连接管理 服务委托管理 配额管理 API版本管理 触发器管理 访问端点管理 obs桶管理 监控指标管理 事件流管理 事件示例管理
修订记录 发布日期 修订记录 2023-02-24 新增获取obs桶列表API接口。 新增预校验指定事件源发布事件成功接口。 新增查询事件通道监控指标数据接口。 新增查询事件订阅监控指标数据接口。 更新查询事件订阅列表接口名称为查询单个函数的EG触发器接口。 新增查询单个函数流的EG触发器接口。
单击已有事件源模块，弹出“事件源”对话框。 修改事件源配置参数。 已创建的订阅，无法修改事件源提供方。 当提供方为“华为云”时，设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。 过滤规则 输入事件过滤规则。 事
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。
MRS集群活动事件，例如集群创建和删除等。 OBS:DWR:ObjectCreated:COPY OBS应用事件源 OPENAPI 3.0 通过OBS Broswer+或Copy请求创建或覆盖对象。 OBS:DWR:ObjectCreated:POST OBS应用事件源 OPENAPI 3.0
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
