检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在OBS目标桶查看对象是否已完成同步 该数据同步功能默认同步后路径一致,在目标桶桶目录下查看文件是否同步成功: 图1 目标桶目录 父主题: 实施步骤
在OBS管理控制台左侧导航栏选择“桶列表”。 在桶列表单击已创建的桶“eg-obs”,进入“对象”页面。 进入待上传的文件夹,单击“上传对象”,系统弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象 父主题: 实施步骤
当选择“精确匹配”时需选择“Topics”。 副本数 请配置副本数。 自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 同步消费进度 请选择是否打开。 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 请选择为“最早”或“最新”。 压缩算法 请选择压缩算法为“none”、“gzip
选择“正则表达式”或“输入/选择”。 说明: 当选择“正则表达式”时需在下方输入表达式。 同步消费进度 请选择是否打开。 打开后会将消息消费进度同步到目标Kafka。 当前同步的进度有100以内的误差。 副本数 请配置副本数。 自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。
项目:选择默认项目 可用区:根据默认项配置 实例名称:输入“eg-kafka” 企业项目:选择“default” 规格类型:默认 版本:3.x CPU架构:x86计算 代理规格:kafka.2u4g.cluster.small 代理数量:配置为“3” 存储空间:高I/O,100GB 磁盘加密:关闭
表示匹配所有Topic,topic.* 表示匹配所有以topic为前缀的Topic。 当选择“精确匹配”时需选择“Topics”。 同步消费进度 请选择是否打开。 说明: 开启时表示将消息消费进度同步到目标Rocketmq。 启动偏移量 请选择为“最早”、“最新”或“自定义”。 压缩算法 请选择压缩算法为“
检查作业所在运行时机器是否能正常连接到源端实例。 目标端连通性检查 检查作业所在运行时机器是否能正常连接到目标端实例。 源端和目标端实例规格检查 检查源端实例和目标端实例的规格是否匹配。 对于预检查结果是告警或者失败的事件流作业,都不会阻塞事件流作业的创建流程,检查结果仅做提示用。 Kafka预检查
401 目标端投递认证失败 主动刷新token,设置事件流状态为ERROR,自动重启事件流。 等待自动恢复。 600 升级中 无动作。 采集函数正在升级,等待升级即可。 403 目标函数被禁用 设置事件流状态为ERROR,上报告警。 检查函数是否正常。 516 topic不存在 检查topic。
源端和目标端实例规格检查 检查源端和目标端Kafka实例的规格是否匹配。 原因:源端和目标端Kafka实例的规格不一致,请检查源端和目标端实例的规格信息。 解决方案:检查配置专业版事件流作业的第二步,即“源和目标对象配置”页面中配置的源端和目标端Kafka实例的规格是否一致,若不一
描述:用户自定义。 源库和目标库配置。 源库类型:“Kafka”和“RocketMQ”。 目标库类型:“Kafka”和“RocketMQ”。 集群节点规格:默认“10 ECU”。 10 ECU支持1~10个并发作业数,10 ECU Kafka最多支持40万QPS,RocketMQ支持3万QPS,DCS支持10万QPS。
当选择“精确匹配”时需选择“Topics”。 副本数 是。 自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 同步消费进度 是。 说明: 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 否。 压缩算法 是,可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。
错误信息 最小长度:1 最大长度:128 表7 flavor 参数 参数类型 描述 name String 规格名称 concurrency_type String 并发规格类型 枚举值: shared exclusive concurrency Integer 并发数 bandwidth_type
data 是 Array of Data objects 数据 subject 否 String 主题 specversion 否 String 规格版本 id 是 String Id source 是 String 事件源 time 是 String 时间 type 是 String 事件类型
在事件列表页面,您还可以导出操作记录文件、刷新列表、设置列表展示信息等。 在搜索框中输入任意关键字,按下Enter键,可以在事件列表搜索符合条件的数据。 单击“导出”按钮,云审计服务会将查询结果以.xlsx格式的表格文件导出,该.xlsx文件包含了本次查询结果的所有事件,且最多导出5000条信息。