Kafka 使用

Kafka 工具通过 Redpanda Console 查看 Kafka 集群状态、Topic、消息、消费组和分区信息，常用于排查消息写入、消费积压和异步链路问题。

页面加载成功后，会在 MDP 内嵌 Redpanda Console。

一、进入 Kafka

在顶部选择 系统服务。

在左侧导航栏展开 中间件工具。

选择 Kafka。

等待 Redpanda Console 加载完成。

如 Console 尚未就绪，页面会提示启动中或启动失败，并展示错误信息。

二、查看集群概览

进入 Kafka 后，默认展示 Overview。

可查看以下信息：

信息	说明
Cluster Status	集群运行状态。
Cluster Storage Size	当前集群存储大小。
Cluster Version	集群版本信息。
Brokers Online	在线 Broker 数量。
Topics	Topic 数量。
Replicas	Replica 数量。
Broker Details	Broker ID、状态和大小。

三、查看 Topic

在 Redpanda Console 左侧导航选择 Topics。

在 Topic 列表中查找目标 Topic。

单击 Topic 进入详情页。

查看 Topic 的分区、消息、配置等信息。

Topic 排查时通常关注：

信息	说明
Partitions	Topic 分区情况。
Messages	Topic 中的消息列表。
Configuration	Topic 配置，例如保留策略。

四、查看消息

进入目标 Topic。

打开消息查看区域。

按页面提供的过滤条件选择分区、位置或时间范围。

查看消息 Key、Value、Headers、Partition、Offset 和时间戳。

消息内容可能包含业务字段。排查时优先使用业务 ID、Key、Offset 和时间戳定位。

五、查看消费组

在 Redpanda Console 左侧导航选择 Consumer Groups。

搜索或选择目标消费组。

进入消费组详情。

查看消费组关联的 Topic、分区、Current Offset、Log End Offset 和 Lag。

六、判断消费积压

状态	说明
Lag 为 0	当前消费组无积压。
Lag 持续上涨	消费速度低于生产速度。
Lag 不变化但不为 0	可能存在消费者停止、分区阻塞或消费失败。
单个分区 Lag 明显偏高	可能是热点 Key 或该分区消费异常。

七、查看 Broker

在 Overview 页找到 Broker Details。

查看 Broker ID、运行状态和存储大小。

单击 View 查看 Broker 详情。

八、常见排查场景

场景	操作建议
确认 Kafka 是否正常	查看 Overview 中 Cluster Status 和 Brokers Online。
确认消息是否写入	进入 Topic 查看 Messages。
排查消费延迟	进入 Consumer Groups 查看 Lag。
定位单条消息	根据 Topic、Partition、Offset、Key 或时间戳查找。
确认 Topic 配置	进入 Topic 详情查看 Configuration。

Kafka

Kafka 使用#

一、进入 Kafka#

二、查看集群概览#

三、查看 Topic#

四、查看消息#

五、查看消费组#

六、判断消费积压#

七、查看 Broker#

八、常见排查场景#

Kafka 使用

一、进入 Kafka

二、查看集群概览

三、查看 Topic

四、查看消息

五、查看消费组

六、判断消费积压

七、查看 Broker

八、常见排查场景