检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
东-上海二 云服务事件源 创建自定义事件源 事件通道 事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下： 云服务事件通道：由事件网格自动创建、且不可修改的一条默认的云服务事件通道，用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表3 响应Body参数
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表4 响应Body参数
支持地域 支持在分布式消息服务Kafka版之间创建事件流的地域有：华东-上海一、华东-上海二、华北-北京四、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
基于Serverless版事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的Serverless版事件流功能实现分布式消息服务Kafka版实例间的数据同步。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 前提条件
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
选择事件发布时间范围。 查询类型 可选择“事件源和事件类型”和“投递状态和订阅名称”。 事件ID 输入事件ID。 单击“事件轨迹”，查看事件轨迹及事件接收、事件投递详情。 图1 查看事件轨迹 单击“事件ID”，可查看事件详情如图2所示。 图2 事件详情 投递失败的事件详情可在72小时内查询到
创建自定义事件源失败的原因？ 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版事件源其状态为“创建失败”或“异常”，可能是以下原因导致： 未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。
基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本文介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。
框。 图3 创建触发器 设置以下信息。 触发器类型：选择“分布式消息服务（Kafka）”。 实例：选择与死信队列相同的Kafka实例。 主题：选择与死信队列相同的Topic。 批处理大小：每次从Topic消费的消息数量，建议设置为10。 用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。
通道：选择账号B创建的通道。 委托：选择带有事件发送权限的委托。 图2 配置事件目标 创建成功后，单击“保存”。 步骤三：发送SMN事件验证 登录消息通知服务SMN控制台。 在左侧导航栏选择“主题管理”，进入“主题”页面。 单击“创建主题”。 输入“主题名称”，选择“企业项目”后单击“确定”。
入门实践 实践 描述 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 基于事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
