检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client
如何获取分布式消息服务Kafka实例的SASL证书地址? 用户在创建事件流,配置事件源为分布式消息服务Kafka版实例时,当Kafka实例开启SASL SSL时,需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。 登录分布式消息服务Kafka控制台。
压缩包里证书的名称必须是固定的:client.jks。 SASL证书被修改时,为保证证书加载生效需区分如下两种情况: 当SASL证书文件名称被修改时,请重新获取证书地址并完成输入,然后单击“保存”。 当SASL证书文件名称未修改时,如果其他参数也未修改,则证书不会重新加载,只有当“Topic”、“消费组”
本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 前提条件 已开通分布式消息Kafka作为事件目标。 事件目标kafka不支持自定义证书。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。
在IAM控制台创建用户组,并授予EG的只读权限。 创建用户并加入用户组。 在IAM控制台创建用户,并将其加入1中创建的用户组。 用户登录并验证权限。 新创建的用户登录控制台,验证EG的只读权限。 父主题: 权限管理
当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 前提条件 背景信息 支持地域 实施及验证
区域:与事件网格所在区域保持一致 桶名称:输入示例如“eg-obs” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图1 创建桶 配置完成后,单击“立即创建”,根据提示信息完成桶的创建。 父主题: 实施步骤
CPU架构:x86计算 代理规格:kafka.2u4g.cluster.small 代理数量:配置为“3” 存储空间:高I/O,100GB 磁盘加密:关闭 容量阈值策略:自动删除 虚拟私有云:vpc-default/subnet-default,此处选择前提条件中已准备好的vpc-default
压缩包格式错误,非ZIP格式。 压缩包格式错误,非ZIP格式。 请检查压缩包格式是否正确 400 EGS.00516011 证书下载地址错误。 证书下载地址错误。 请检查证书下载地址 400 EGS.00516012 下载OBS文件失败。 下载OBS文件失败。 请联系管理员 400 EGS
通道:选择账号B创建的通道。 委托:选择带有事件发送权限的委托。 图2 配置事件目标 创建成功后,单击“保存”。 步骤三:发送SMN事件验证 登录消息通知服务SMN控制台。 在左侧导航栏选择“主题管理”,进入“主题”页面。 单击“创建主题”。 输入“主题名称”,选择“企业项目”后单击“确定”。
PLAIN ssl_certificate_url 否 String SASL证书地址,配置的obs地址 最小长度:1 最大长度:512 ssl_certificate_pwd 否 String SASL证书密码 最小长度:1 最大长度:256 user_name 否 String 用户名
SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址,配置的obs地址 最小长度:1 最大长度:512 ssl_certificate_pwd String SASL证书密码 最小长度:1 最大长度:256 user_name String 用户名
SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址,配置的obs地址 最小长度:1 最大长度:512 ssl_certificate_pwd String SASL证书密码 最小长度:1 最大长度:256 user_name String 用户名
PLAIN ssl_certificate_url 否 String SASL证书地址,配置的obs地址 最小长度:1 最大长度:512 ssl_certificate_pwd 否 String SASL证书密码 最小长度:1 最大长度:256 user_name 否 String 用户名
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”,进入“目标连接”页面。 单击“创建目标连接”,弹出“创建目标连接”对话框。 首次创建目标连接时,系统会自动弹出创建委托授权界面,需要您创建授权委托,详情请查看授权委托。 配置如下目标连接参数。更
事件目标:分布式消息服务 Kafka版 目标连接:选择“kafka-connect” Topic:选择“topic-eg” 启用消息Key:关闭 规则配置类型:透传。配置转换规则请参考事件内容转换 单击“保存”,完成订阅的配置。 父主题: 实施步骤
cn-north-4.myhuaweicloud.com"; private static final String URL = "https://" + ENDPOINT + "/v1/" + PROJECT_ID + "/channels/" + CHANNEL_ID + "/events";
调用说明 事件网格提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 父主题: 使用前必读
区域:与事件网格所在区域保持一致 桶名称:输入“eg-test” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图4 创建桶 单击“立刻创建”,根据提示信息完成桶的创建。 步骤四:查看结果 登录函数工作流控制台。
RocketMQ版实例时,需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。 https://ecloud.10086.cn/op-help-center/doc/article/67668 请下载1.4.0版本的 Java