检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
如何获取分布式消息服务Kafka实例的SASL证书地址？ 用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。 登录分布式消息服务Kafka控制台。
apache.http.conn.ssl.NoopHostnameVerifier; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
参数修改时，单击“保存”后，证书才会重新加载。 SASL证书密钥 当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。 用户名 当Kafka实例开启SASL SSL时可见，输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。
检查AK/SK是否正确，如果需要重新获取AK/SK，请参考获取AK/SK。 请求鉴权失败。 检查发布事件的请求方法、请求地址和请求体与利用验签算法生成签名时的参数是否一致。 资源不存在。 请检查事件通道、事件源、事件订阅等是否创建成功并且正确配置。 事件体的格式不正确。 请检查事件是否符合
当Kafka实例开启SASL SSL时可见，选择SASL认证机制。 PLAIN：一种简单的用户名密码校验机制。 SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见，输入
求进行加密签名。 SK(Secret Access Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。 使用AK/SK认证时，您可以基于签名算法使用AK/SK对请求进行签名，也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。
enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值： SCRAM-SHA-512 PLAIN ssl_certificate_url 否 String SASL证书地址，配置的obs地址
earliest enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值： SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址，配置的obs地址 最小长度：1
enable_sasl_ssl 否 Boolean SASL_SSL是否开启 sasl_mechanism 否 String SASL认证机制 枚举值： SCRAM-SHA-512 PLAIN ssl_certificate_url 否 String SASL证书地址，配置的obs地址
earliest enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值： SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址，配置的obs地址 最小长度：1
本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 前提条件 已开通分布式消息Kafka作为事件目标。 事件目标kafka不支持自定义证书。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，进入“Serverless版事件流”页面。
EGS.00516011 证书下载地址错误。 证书下载地址错误。 请检查证书下载地址 400 EGS.00516012 下载OBS文件失败。 下载OBS文件失败。 请联系管理员 400 EGS.00516013 文件上传OBS失败。 文件上传OBS失败。 请联系管理员 400 EGS.00516015
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更
当选择为密文接入时会显示对应的安全协议。 SASL_SSL 认证机制 Kafka实例开启SASL_SSL认证时可见，选择SASL_SSL 认证机制。 PLAIN：一种简单的用户名密码校验机制。 SCRAM-SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。
enable_sasl_ssl 是 Boolean kafka实例是否开启了SASL_SSL。 缺省值：false user_name 否 String kafka实例用户名。实例开启了SASL_SSL时必填 password 否 String kafka实例密码。实例开启了SASL_SSL时必填
应值，该接口是唯一不需要认证的接口。 API同时支持使用AK/SK认证，AK/SK认证是使用SDK对请求进行签名，签名过程会自动往请求中添加Authorization（签名认证信息）和X-Sdk-Date（请求发送的时间）请求头。 AK/SK认证的详细说明请参见AK/SK认证。
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值：false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值：false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
enable_sasl_ssl Boolean kafka实例是否开启了SASL_SSL。 缺省值：false user_name String kafka实例用户名。实例开启了SASL_SSL时必填 password String kafka实例密码。实例开启了SASL_SSL时必填 acks
虚拟私有云 subnet_id 否 String 子网 namesrv_address 否 String 连接地址 ssl_enable 否 Boolean SSL enable_acl 否 Boolean ACL访问控制 响应参数 状态码： 200 表5 响应Header参数 参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
