【 Offset Explorer 3.0.3使用说明】

Offset Explorer 3.0.3 是一个用于管理和监控 Apache Kafka 集群的图形化工具。它允许用户查看 Kafka 的主题（Topics）、分区（Partitions）、消费者组（Consumer Groups）以及偏移量（Offsets）等信息。

一、Kafka Offset 是什么？

在 Kafka 中，Offset（偏移量） 是一个消息在分区中的唯一标识符，表示该消息在分区中的位置。每个消息都有一个唯一的 offset，从 0 开始递增。 消费者通过记录自己消费到的 offset 来实现“从哪里开始消费”。 Kafka 不会自动删除已消费的消息，而是保留一段时间（由 retention.ms 控制），直到被清除或过期。 消费者组（Consumer Group）会将每个分区的消费进度（offset）提交到 Kafka 的 __consumer_offsets 主题中。

在这里插入图片描述

二、Offset Explorer 使用手册

功能概览

功能 描述

浏览 Broker 和 Topics 查看集群结构和所有 Topic 查看 Partition 详情 包括 Leader、Replicas、ISR 等 查看 Consumer Group 偏移量 显示各 consumer group 在每个 partition 上的消费进度 数据浏览 可以查看 Topic 中的实际消息内容 配置管理 查看 Topic 的配置参数

三、如何使用 Offset Explorer 查看 Offset

在这里插入图片描述

1. 连接 Kafka 集群 打开 Offset Explorer 点击左上角菜单：File → Add Broker 输入 Kafka Broker 地址（如 localhost:9092） 添加成功后会在左侧树形结构中显示 Broker
2. 浏览 Topics 展开 Brokers → Topics 点击某个 Topic，右侧会显示其属性（Properties）、数据（Data）、分区（Partitions）和配置（Config）
3. 查看 Partition 的 Offset 进入某个 Topic 后，点击 Partitions 标签页 你会看到每个分区的： Partition ID High Watermark (HW)：当前最新消息的 offset（即生产者写入的位置） Log End Offset (LEO)：日志末尾的 offset Consumer Offset：消费者已经消费到的位置（如果存在消费者组）
4. 查看 Consumer Group 的 Offset 在左侧导航栏选择 Consumer Groups 选择某个 consumer group，即可看到它在各个 topic-partition 上的： Current Offset（当前消费偏移） Commit Offset（提交的偏移） Lag（滞后量 = HighWatermark - Current Offset）
5. 重置 Offset（重要功能） 右键点击某个 consumer group 的 partition 选择 Reset Offset 或 Set Offset to… 可设置为： 最早（Earliest） 最新（Latest） 某个具体 offset 时间点（如 1 小时前） 注意：重置 offset 会影响消费者后续读取的数据，需谨慎操作！
6. 查看消息内容 切换到 Data 标签页 选择一个 partition，可以查看该 partition 的消息 支持过滤、排序、查看 JSON/Text 内容
7. 导出与保存 可导出 consumer offset 信息到 CSV 文件 支持保存连接配置

四、常见使用场景

场景 如何操作

监控消费者是否卡住 查看 Lag 是否持续增长 定位消费延迟问题 检查 lag 数值变化趋势 重启消费者后恢复消费 使用 Reset Offset 设置起始位置 排查数据丢失 对比 high watermark 和 consumer offset 调试 Kafka Stream 应用 查看 KStream/KTable 的状态存储 topic

五、注意事项

1. 不要随意修改 offset 修改 offset 可能导致重复消费或数据跳过 生产环境建议先备份再操作
2. 注意权限控制 某些 Kafka 集群启用了 SASL/SSL 认证 需要在 Offset Explorer 中配置认证信息
3. 性能影响 大量 Topic 或分区可能导致 UI 卡顿 建议使用过滤器只加载关心的内容
4. 版本兼容性 Offset Explorer 3.x 支持 Kafka 0.8+ 版本 新版 Kafka（如 3.x）可能需要更新插件或使用替代工具（如 Confluent Control Center、Kafka Manager）

六、推荐替代工具（现代方案）

工具 说明

Confluent Control Center 官方推荐，功能强大，适合企业级部署 Kafka Manager 开源管理平台，支持多集群 Kafka Tool 图形化工具，支持更多高级功能 kcat 命令行工具，适合脚本自动化

📎 附录：命令行查看 Offset 示例（可选）

bash 查看指定 topic 的 offset kafka-consumer-groups.sh --bootstrap-server localhost:9092 –describe --group my-group 查看所有 consumer groups kafka-consumer-groups.sh --bootstrap-server localhost:9092 –list 重置 offset 到 earliest kafka-consumer-groups.sh --bootstrap-server localhost:9092 –group my-group –topic my-topic –reset-offsets --to-earliest --execute

总结

Offset Explorer 是一个非常实用的 Kafka 图形化工具，尤其适合开发和运维人员快速排查消费异常、监控消费进度、调试流处理应用。