检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单击“确定”，完成目标连接的创建。 创建分布式消息服务Kafka版目标连接 在创建目标连接前，已准备好分布式消息服务Kafka版实例。 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委
图2 配置事件源 选择事件源提供方。 云服务：云服务事件源作为事件源提供方。 自定义：您自定义的事件源作为事件源提供方。 设置事件源参数。 当提供方为“云服务”时，设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型（可选） 选择事件网格预定义的事件类型。
基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本文介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
分布式消息服务RabbitMQ版 本章节介绍在控制台添加分布式消息服务RabbitMQ版自定义事件源的方法。 分布式消息服务RabbitMQ版当前支持局点：上海一、上海二、北京四、华北-乌兰察布一、华南-广州。 前提条件 （可选）创建自定义事件源前，需要先创建自定义事件通道。 已
分布式消息服务RocketMQ版 本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。 前提条件 （可选）创建自定义事件源前，需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于“运行中”。具体步骤，请参考购买实例。
Error" } 状态码 状态码 描述 200 Information 400 非法请求 401 未授权 403 禁止访问 404 未找到资源 500 内部服务错误 错误码 请参见错误码。 父主题： 事件订阅管理
如何获取分布式消息服务Kafka实例的SASL证书地址？ 用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。
成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。
确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图1 分布式消息服务 Kafka版 表1 分布式消息服务 Kafka版参数说明 参数名称
分布式消息服务Kafka版 本章节介绍在创建事件流时，如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例，详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口，详情
证。 使用AK/SK认证时，签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。 Token认证 Token的有效期为24小时，需要使用一个Token鉴权时，可以先缓存起来，避免频繁调用。 Token在计算机系统中代表令牌（临时）的意思，拥有Token就代表拥有某种权
Error" } 状态码 状态码 描述 200 Information 400 非法请求 401 未授权 403 禁止访问 404 未找到资源 500 内部服务错误 错误码 请参见错误码。 父主题： 事件订阅管理
续费 如需续费，请在管理控制台“续费管理”页面进行续费操作，如图1所示。详细操作请参考续费管理。 图1 续费管理
前支持2.7及以上，后续支持版本会持续更新。 源Kafka和目标Kafka实例的规格、存储空间需保持一致。 确保vpc、子网、kafka等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤
状态码 状态码 描述 200 Demo Information 400 非法请求 401 未授权 403 禁止访问 404 未找到资源 500 内部服务错误 错误码 请参见错误码。 父主题： 事件订阅管理
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时，目标端只支持选择FunctionGraph（函数计算）。
创建事件源如何配置安全组？ 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版自定义事件源之前，需要正确配置安全组规则。 分布式消息服务所属的安全组“入方向规则”配置错误，会导致事件目标函数工作流无法消费事件； 用户default安全组“出方向规则”配置错误，事件源会创建失败。
Server Error" } 状态码 状态码 描述 200 配额 400 非法请求 401 未授权 403 禁止访问 404 未找到资源 500 内部服务错误 错误码 请参见错误码。 父主题： 配额管理
x、5.x。 源RocketMQ和目标RocketMQ实例的规格、Broker数量、存储空间需保持一致。 确保vpc、子网、RocketMQ等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤
支持CloudEvents SDK和API。 高并发&高可用 支持千万级事件并发。 服务可用性99.99%，采用分布式集群化部署，具备极强的容灾能力。 安全可靠 对接统一身份认证服务、云日志服务、云监控服务和云审计服务等安全管理服务，全方位保护事件的存储与访问。 持久化数据支持磁盘和用户指定密钥加密，进一步提高数据的安全性。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
