检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SSL 请选择是否开启SSL。 ACL访问控制 请选择是否开启ACL访问控制。 说明: 当开启ACL访问控制时,需要配置用户名及密钥。 tag 请输入tag。 消费点位 请选择最早、最新或自定义。 说明: 当消费点位选择自定义时,需要配置日期时间。
String SASL认证机制 枚举值: SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址,配置的obs地址 最小长度:1 最大长度:512 ssl_certificate_pwd String SASL证书密码 最小长度
flavor object 规格 type String 目标连接类型。
父主题: 事件源管理
当源端和目标端均为Kafka时: 图3 源端和目标端配置 源端类型:Kafka 目标端类型:Kafka 规格(QPS):选择为2000、5000、9000、15000或>20000。 表2 源端目标端配置参数说明 参数 说明 配置类型 请选择“Kafka地址”或“实例名称”。
实例 请选择实例。 Group 请输入消费组。 Topic 请输入Topic。 SSL 请选择是否开启SSL。 ACL访问控制 请选择是否开启ACL访问控制。 说明: 当开启ACL访问控制时,需要配置用户名及密钥。
检查源端和目标端RocketMQ实例的规格是否匹配。 原因:源端和目标端RocketMQ实例的实例类型不一致,请检查源端实例和目标端实例的规格信息。
父主题: 事件源管理
检查配置专业版事件流作业的第二步,即“源和目标对象配置”页面中配置的目标端Kafka实例的用户名和密码是否正确。 源端和目标端实例规格检查 检查源端和目标端Kafka实例的规格是否匹配。 原因:源端和目标端Kafka实例的规格不一致,请检查源端和目标端实例的规格信息。
图1 源数据和目标数据配置 表1 源数据目标数据配置参数是否支持修改说明 参数 是否支持修改 配置类型 否。 实例别名 否。 区域 否。 项目 否。 Kafka实例 否。 接入方式 是,支持“明文接入”或“密文接入”。 安全协议 是。
源RocketMQ和目标RocketMQ实例支持的版本:4.x、5.x。 源RocketMQ和目标RocketMQ实例的规格、Broker数量、存储空间需保持一致。 确保vpc、子网、RocketMQ等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。
事件源类型 事件源类型,选择“分布式消息服务RabbitMQ版”。 说明: 如之前未创建授权委托,事件源类型首次选择“分布式消息服务RabbitMQ版”时,系统会自动弹出创建委托授权界面,需要您创建授权委托,详情请查看授权委托。
import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.TrustSelfSignedStrategy; import org.apache.http.entity.StringEntity
网络与安全 支持SSL等加密和认证机制,让数据同步更安全。 多种同步模式 支持对象选择、全量+增量同步和多种压缩模式,满足不同同步诉求。 预检查 预检查支持提前识别同步是否满足成功条件,提供失败原因、失败详情和处理建议信息。
接入点类型 请选择公网或私网。 地址 请输入地址。 客户端SDK 请输入客户端SDK上传到OBS的地址。 说明: 客户端SDK上传到OBS的地址获取方式可参考常见问题。 消费超时时间(毫秒) 请输入1000到900000之间的整数。 消息类型 请选择普通消息。
用户在创建事件流时,配置事件源为移动云 RocketMQ版实例时,需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。
检查是否创建所需私网访问端点,其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同,具体步骤,请参考创建私网访问端点。 用户default安全组规则配置不正确。 default安全组“出方向规则”需放通ICMP协议全部端口,具体步骤,请参考添加安全组规则。
父主题: 事件源管理
源库类型:“Kafka”和“RocketMQ”。 目标库类型:“Kafka”和“RocketMQ”。 集群节点规格:默认“10 ECU”。
目标端连通性检查 检查作业所在运行时机器是否能正常连接到目标端实例。 源端和目标端实例规格检查 检查源端实例和目标端实例的规格是否匹配。 对于预检查结果是告警或者失败的事件流作业,都不会阻塞事件流作业的创建流程,检查结果仅做提示用。