视频帮助 - 分布式消息服务Kafka版
None 服务介绍 分布式消息服务介绍 04:19 介绍什么是分布式消息服务 Kafka:数据流转的桥梁 02:03 Kafka-数据流转的桥梁 特性讲解 消息积压诊断 03:18 消息积压诊断 Kafka分区平衡 02:49 Kafka分区平衡 操作指导 购买Kafka实例 07
典型应用场景 - 分布式消息服务Kafka版
典型应用场景 Kafka作为一款热门的消息队列中间件,具备高效可靠的消息异步传递机制,主要用于不同系统间的数据交流和传递,在企业解决方案、金融支付、电信、电子商务、社交、即时通信、视频、物联网、车联网等众多领域都有广泛应用。
审计与日志 - 分布式消息服务Kafka版
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。
消息从生产到消费时延高达6分钟 - 分布式消息服务Kafka版
详细分析 查看用户消费组行为日志文件,文件中存在以下三种日志: Preparing to rebalance group 1 表示消费组开始进行rebalance,消费组状态变更为REBALANCING。
什么是分布式消息服务Kafka版 - 分布式消息服务Kafka版
介绍视频
修改Kafka分区平衡 - 分布式消息服务Kafka版
操作视频 本视频演示修改Kafka实例分区平衡的操作。 因产品功能演进,操作界面可能存在差异,相关视频仅供参考,具体以实际环境为准。 约束与限制 单机实例不支持修改分区平衡。 分区平衡任务启动后,无法修改Topic的分区数。
诊断Kafka消息积压 - 分布式消息服务Kafka版
介绍视频 前提条件 已创建Kafka实例,并且消费组正在以非assign方式消费消息中。 一个消费组正在诊断中时,无法对其他消费组进行诊断,也无法对此消费组消费的其他Topic进行诊断。 操作流程 图1 消息积压诊断流程图 步骤一:诊断前检查 登录Kafka控制台。
漏洞修复策略 - 分布式消息服务Kafka版
修复声明 为了防止客户遭遇不当风险,除漏洞背景信息、漏洞详情、漏洞原理分析、影响范围/版本/场景、解决方案以及参考信息等内容外,分布式消息服务Kafka版不提供有关漏洞细节的其他信息。 此外,分布式消息服务Kafka版为所有客户提供相同的信息,以平等地保护所有客户。
成本管理 - 分布式消息服务Kafka版
资源优化 您可以通过云监控服务监控资源的使用情况,识别空闲资源,寻找节约成本的机会。也可以根据成本分析阶段的分析结果识别成本偏高的资源,然后采取针对性的优化措施。 监控资源利用率,评估当前配置是否过高。例如:CPU、内存、云硬盘等资源的利用率。 监控闲置的资源,避免浪费。
计费样例 - 分布式消息服务Kafka版
计费构成分析 可以将Kafka实例的使用阶段按照计费模式分为两段:在2023/03/18 15:30:00 ~ 2023/03/20 10:30:00期间为按需计费,2023/03/20 10:30:00 ~ 2023/04/20 23:59:59期间为包年/包月计费。
查看Kafka Topic日志 - 分布式消息服务Kafka版
在左侧导航栏选择“分析与诊断 > Topic日志”,进入“Topic日志”页面。 在“日志查询”页签,查看Topic日志。 如果您需要搜索日志,请参考进入搜索LTS日志页面。
提高Kafka消息处理效率 - 分布式消息服务Kafka版
当消息的生产和消费过程中遇到疑难问题时,通过创建不同消费组可以帮助定位分析问题或调试服务对接。用户可以创建一个新的消费组,对Topic中的消息进行消费并分析消费过程,这样不会影响其他服务对消息的处理。
Kafka消息堆积了怎么办? - 分布式消息服务Kafka版
在左侧导航栏,选择“分析与诊断 > 消息积压诊断”,进入消息积压诊断页面。 选择需要诊断的消费组名称和Topic名称,单击“诊断前检查”。 诊断前检查成功后,如果“消息积压情况”显示有消息积压,并且消费组正在以非assign方式消费消息中,单击“开始诊断”。
实例使用类接口 - 分布式消息服务Kafka版
实例使用类接口 查询分区指定偏移量的消息 查询分区指定时间段的消息 查询分区最新消息的位置 查询分区最早消息的位置 查询Kafka集群元数据信息 查询消费组信息 重置消费组消费进度到指定位置 查询Kafka实例所有消费组对应的协调器信息 查询Kafka实例Topic详细信息 新增Kafka
查看Kafka重平衡日志 - 分布式消息服务Kafka版
在左侧导航栏单击“分析与诊断 > 重平衡日志”,进入“重平衡日志”页面。 单击“开启日志”,弹出“开启日志”对话框。 单击“确定”,弹出“日志配置”对话框。
Kafka Topic分区数设置建议 - 分布式消息服务Kafka版
典型问题案例 表2 典型问题案例 问题现象 根因分析 处理建议 使用ClickHouse消费Kafka,其中Topic分区数为12,ClickHouse节点数为10,ClickHouse表参数中已配置consumer_num=12(即10个节点共有120个消费者),问题现象为仅1个
产品功能 - 分布式消息服务Kafka版
标签 标签是Kafka实例的标识,为Kafka实例添加标签,可以方便用户识别和管理拥有的Kafka实例资源。 您可以在创建Kafka实例时添加标签,也可以在Kafka实例创建完成后,在实例的详情页添加标签。详情请参见配置Kafka实例标签。
配置Kafka实例标签 - 分布式消息服务Kafka版
配置Kafka实例标签 标签是Kafka实例的标识,为Kafka实例添加标签,可以方便用户识别和管理拥有的Kafka实例资源。 如您的组织已经设定分布式消息服务Kafka版的相关标签策略,则需按照标签策略规则为Kafka实例添加标签。
分布式消息服务Kafka版计费概述 - 分布式消息服务Kafka版
成本管理 您可以从成本构成、成本分配、成本分析和成本优化四个维度来管理成本。更多详情,请参见成本管理。 产品定价 如您需要快速了解分布式消息服务Kafka版的具体价格,请参见分布式消息服务Kafka版价格详情。
DMS for Kafka安全使用建议 - 分布式消息服务Kafka版
云审计服务(Cloud Trace Service,CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。

