检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。 登录分布式消息服务Kafka控制台。 在分布式消息服务Kafka专享版页面，单击Kafka实例。
压缩包里证书的名称必须是固定的：client.jks。 SASL证书密钥 当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。 用户名 当Kafka实例开启SASL SSL时可见，输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。
启用专业版事件流作业 本章节指导您在控制台里启用专业版事件流作业。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流＞专业版事件流作业”，进入“专业版事件流作业”页面。 单击操作列“启用”或选中多个事件流作业后单击“批量修改状态 > 启用”按钮，弹出启用事件流作业成功的弹窗时，即完成专业版事件流作业的启用。
Kafka实例开启SASL_SSL认证时可见，选择SASL_SSL 认证机制。 PLAIN：一种简单的用户名密码校验机制。 SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。 用户名 Kafka实例开启SASL_SSL认证时可见，输入实例用户名。
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息，请参考事件内容转换。 启用死信队列：默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中，若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图8 自定义事件目标配置参数 单击“确定”，完成事件目标的配置。
对象名编码：开启 过滤规则：根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。 配置事件目标。 配置如下事件目标参数： 选择提供方：华为云 事件目标：分布式消息服务 Kafka版 目标连接：选择“kafka-connect” Topic：选择“topic-eg” 启用消息Key：关闭
用户名：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。 密码：Kafka实例开启SSL时需要填写。连接Kafka专享版实例的密码。 单击“确定”，完成kafka触发器的创建。 单击“启用”，启用kafka触发器。 图4 启用Kafka触发器 编写死信数据的处理逻辑。
如果需要了解更多转换类型的信息，请参考事件内容转换。 消息推送 批量推送 配置是否开启批量推送，批量推送可帮您批量聚合多个事件。 批量推送条数 推送间隔 开启批量推送可见，每次批量推送的最大聚合条数，默认值100，输入值范围1~10000。 开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息，请参考事件内容转换。 启用死信队列：默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中，若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图5 自定义事件目标配置参数 单击“确定”。
操作事件订阅 功能介绍 操作事件订阅，支持启用、禁用。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/subscriptions/operation
函数触发器 场景二：云服务事件流转 事件网格作为华为云的标准事件中心，可以实现各个云服务之间的联动。 云服务作为事件源或者事件目标部署在华为云的无服务器（Serverless）应用平台上，应用推送业务实时事件到事件网格，事件网格对事件进行过滤、路由和转化，从而触发订阅事件的云服务。 图2 云服务事件流转
TagC 表示订阅TagA或TagB或TagC的消息。 开启保存消息轨迹 请选择是否开启保存消息轨迹。 启用鉴权认证 请选择是否启用鉴权认证。 Access Key（启用鉴权认证） 请输入Access Key。 Secret Key（启用鉴权认证） 请输入Secret Key。 订阅方式
云搜索服务 CSS 视频分析服务 VAS 数据管理服务 DAS 裸金属服务器 BMS 云测 CloudTest VPC终端节点 VPCEP 云存储网关服务 CSG 虚拟专用网络 VPN 企业路由器 ER 推荐系统 RES 云服务器备份服务 CSBS 内容分发网络服务 CDN 容器安全服务 CGS
完成参数配置后单击“立即购买”，完成事件路由创建，创建成功后可在事件路由页面查看任务状态。 事件路由任务创建完成后默认为“未启用”状态，需要单击“启用”按钮，待状态显示为“运行中”时，任务正式启用。 图5 启用事件路由 父主题： 事件路由
请求什么类型的操作。 GET：请求服务器返回指定资源。 PUT：请求服务器更新指定资源。 POST：请求服务器新增资源或执行特殊操作。 DELETE：请求服务器删除指定资源，如删除对象等。 HEAD：请求服务器资源头部。 PATCH：请求服务器更新资源的部分内容。当资源不存在的时
SASL证书密钥 当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。从Kafka实例详情页获取的SASL证书，证书密钥固定为：dms@kafka。 用户名 当Kafka实例开启SASL SSL时可见，输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。
从0到1，带您快速了解事件发送流程，开启您的事件网格使用之旅。 入门指导 开通事件网格服务并授权 华为云服务事件发送流程 自定义事件发送流程 05 实践 弹性云服务器（Elastic Cloud Server）是一种可随时自动获取、计算能力可弹性伸缩的云服务器。 部署web环境 什么是ECS 创建容器应用基本流程
Failed 未满足前提条件，服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大，服务器无法处理，因此拒绝请求。为防止客户端的连续请求，服务器可能会关闭连接。如果只是服务器暂时无法处理，则会包含一个Retry-After的响应信息。
由的能力。 事件源 事件源是事件的来源，负责生产事件。事件网格支持以下事件源： 华为云服务事件源：华为云服务作为事件源，华为云服务包含弹性云服务器、对象存储服务和云容器引擎等等。 自定义事件源： 支持自定义应用通过事件网格提供的SDK接入，作为事件源。 支持分布式消息服务Rabb
专业版事件流作业 创建专业版事件流作业 删除专业版事件流作业 启用专业版事件流作业 停用专业版事件流作业 配置专业版事件流作业 父主题： 专业版事件流
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
