如需了解国际站更多云产品，请访问国际站。https://www.huaweicloud.com/intl/
不再显示此消息
如需了解国际站更多云产品，请访问国际站。https://www.huaweicloud.com/intl/
不再显示此消息
如何获取分布式消息服务Kafka实例的SASL证书地址？ 用户在创建事件流，配置事件源为分布式消息服务Kafka版实例时，当Kafka实例开启SASL SSL时，需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。 登录分布式消息服务Kafka控制台。
更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M； 压缩包里证书的名称必须是固定的：client
据都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 请求示例 更新目标连接 PUT https://{endpoint}/v1/{project_id}/connections/{connection_id} { "description"
压缩包里证书的名称必须是固定的：client.jks。 SASL证书被修改时，为保证证书加载生效需区分如下两种情况： 当SASL证书文件名称被修改时，请重新获取证书地址并完成输入，然后单击“保存”。 当SASL证书文件名称未修改时，如果其他参数也未修改，则证书不会重新加载，只有当“Topic”、“消费组”、“
路由到分布式消息服务Kafka版 本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 约束与限制 事件目标kafka不支持自定义证书。 前提条件 已开通分布式消息Kafka作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更
</dependency> “cloudevents.version”使用最新版本2.2.0。 发布事件 发布事件的示例代码如下（以下加粗内容需要请根据实际情况替换）： import com.alibaba.fastjson.JSONObject; import io.cloudevents.CloudEvent;
都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 请求示例 创建目标连接 POST https://{endpoint}/v1/{project_id}/connections { "name" : "private-link"
不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 请求示例 查询目标连接列表 GET https://{endpoint}/v1/{project_id}/connections 响应示例 状态码：200 列表 { "total"
RocketMQ版实例时，需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。 https://ecloud.10086.cn/op-help-center/doc/article/67668 请下载1.4.0版本的 Java
String SASL认证机制 ssl_certificate_url 否 String SASL证书地址，配置的obs地址 ssl_certificate_pwd 否 String SASL证书密码 user_name 否 String 用户名 password 否 String 用户密码
不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 请求示例 查询目标连接详情 GET https://{endpoint}/v1/{project_id}/connections/{connection_id} 响应示例 状态码：200
错误码 error_detail String 错误详情 error_msg String 错误信息 请求示例 更新自定义事件源 PUT https://{endpoint}/v1/{project_id}/sources/{source_id} { "description"
压缩包格式错误，非ZIP格式。 请检查压缩包格式是否正确 400 EGS.00516011 Invalid download URL. 证书下载地址错误。 请检查证书下载地址 400 EGS.00516012 Download OBS file failed. 下载OBS文件失败。 请联系管理员
String 检查失败的原因 solution String 检查失败的解决方案 请求示例 校验jobid=123的专业版事件流作业 POST https://{eg_endpoint}/v1/{project_id}/eventrouter/jobs/validation?validat
String SASL认证机制 ssl_certificate_url 否 String SASL证书地址，配置的obs地址 ssl_certificate_pwd 否 String SASL证书密码 user_name 否 String 用户名 password 否 String 用户密码
错误码 error_detail String 错误详情 error_msg String 错误信息 请求示例 创建自定义事件源 POST https://{endpoint}/v1/{project_id}/sources { "name" : "first-source",
String SASL认证机制 ssl_certificate_url String SASL证书地址，配置的obs地址 ssl_certificate_pwd String SASL证书密码 user_name String 用户名 password String 用户密码 表9
String SASL认证机制 ssl_certificate_url String SASL证书地址，配置的obs地址 ssl_certificate_pwd String SASL证书密码 user_name String 用户名 password String 用户密码 表7
true：使用从节点同步数据 false：不使用从节点同步数据，即使用主节点 请求示例 查询jobId=123的专业版事件流作业详情 GET https://{eg_endpoint}/v1/{project_id}/eventrouter/jobs/123 响应示例 状态码：200 请求成功
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
您即将访问非华为云网站，请注意账号财产安全
