Kafka 管控台使用手册

本文档说明 ADMQ Manager 中 Kafka 用户侧的常用页面、主要功能及关键配置项。

前提条件：

• ADMQ Manager 已部署完成并可正常访问
• Kafka 集群已完成部署或接入
• 当前账号可进入 Kafka 用户侧页面

---

一、菜单概览

Kafka 用户侧常用菜单分为四类：

菜单	说明
概览	集群基础信息、连接地址、在线状态
资源管理	主题（Topic）和订阅组（Consumer Group）管理
消息查询	按主题/时间/偏移量查询历史消息
监控运维	吞吐量、延迟、消费积压等指标

---

二、核心概念

在使用管控台之前，需先理解以下 5 个基本概念：

2.1 主题（Topic）

消息的业务分类，生产者发送到某个主题，消费者从主题中消费。

示例：order-create（订单创建消息）、payment-result（支付结果消息）

2.2 分区（Partition）

主题内部的并行通道，分区越多并行处理能力越强，但管理复杂度也越高。

2.3 副本（Replica）

分区数据的备份份数，副本数越大可用性越高，但资源占用也越大。

2.4 订阅组（Consumer Group）

消费同一批消息的一组消费者，不同订阅组之间互不影响，同组内协同消费。

2.5 偏移量（Offset）

标记"读到哪条消息了"的指针。重置偏移量会改变消费起点，是高风险操作，操作前请确认影响范围。

---

三、概览页面

概览页展示 Kafka 集群的基础状态，主要关注：

区域	内容
资源概览	主题数量、订阅组数量
连接信息	Kafka 连接地址（业务接入时使用）
服务状态	集群是否在线

使用场景： 快速确认环境信息——"这个集群是谁的、能不能连、当前资源大概有多少"。

---

四、主题管理

4.1 主题列表

在 资源管理 → 主题 页面可以：

• 查看当前已有主题
• 创建新主题
• 进入主题详情

4.2 新增主题

点击 新增 按钮，填写以下字段：

主题名称

推荐命名规范：

示例	说明
order-create	订单创建事件
payment-result	支付结果通知
inventory-change	库存变更事件

不推荐： test1、aaa、topic001 等无意义名称

分区数量

环境	建议值
测试环境	3
生产环境（初始）	3 或 6

分区数创建后可增加但不能减少，初始不宜设过大。

副本数

环境	建议值
测试环境	1（或集群默认）
生产环境	3

副本数不能超过集群节点数。

4.3 主题详情操作

进入主题详情后可以：

• 发送消息：向该主题发送测试消息
• 查看消息：浏览历史消息内容
• 修改配置：调整保留时长、最大消息大小等

---

五、订阅组管理

在 资源管理 → 订阅组 页面管理 Consumer Group：

操作	说明
新增订阅组	填写组名，创建消费者组
查看消费进度	查看各分区的消费偏移量和积压量
重置偏移量	⚠️ 高风险操作，会影响消费起点

---

六、消息查询

在 消息查询 页面，可按以下方式查询历史消息：

• 选择主题
• 选择分区
• 按时间范围 或 偏移量范围 筛选
• 查看消息内容（支持 JSON 格式化展示）

---

七、监控运维

监控运维页面提供：

指标	说明
生产速率	每秒消息写入量（TPS）
消费速率	每秒消息消费量
消费积压	未消费消息数量，积压过大需告警
Broker 状态	各节点 CPU、内存、磁盘使用情况

---

如需技术支持，请联系 Apusic 技术支持团队。