AKHQ UI 0.24.0中Kafka消息计数不匹配问题求助

问题现象 #

• 向Kafka Topic生产10条记录，消费端可完整获取全部10条，手动统计消息数量也与生产数一致
• AKHQ UI中显示该Topic消息计数为12，切换排序为「最新」后问题依旧
• 偏移量区间存在异常：153-161跨度9但实际仅7条记录，132-136跨度5实际仅3条记录，AKHQ计数明显是按偏移量跨度计算，而非实际消息数量

问题根源分析 #

1. AKHQ计数逻辑缺陷：AKHQ默认可能通过「结束偏移量 - 起始偏移量 + 1」估算消息总数，而非实际遍历扫描每条消息。若Topic存在消息被清理（如过期自动删除、手动清理）或分区重新分配导致偏移量不连续，就会出现这种“虚高计数”。
2. 空消息/无效记录干扰：生产者可能意外发送空消息（字节数为0），这类消息在消费时可能被业务代码过滤，但AKHQ会将其计入总数；另外也可能存在已标记为消费但未清理的偏移量占位。

排查&修复方案 #

1. 强制AKHQ重新扫描Topic：在AKHQ的Topic详情页找到刷新按钮（一般在页面右上角或操作栏），让AKHQ重新遍历实际消息计数，而非依赖偏移量差值估算。
2. 检查Topic清理策略：查看Topic的cleanup.policy配置，若为delete或compact，确认是否有消息被自动清理导致偏移量断层。可通过Kafka命令行验证实际偏移量：

   kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <你的Broker地址> --topic <目标Topic名> --time -1
   

   获取各分区最新偏移量后，对比起始偏移量，结合消费统计判断实际消息数。
3. 排查空消息：用命令行消费者查看Topic所有消息，确认是否存在空消息：

   kafka-console-consumer.sh --bootstrap-server <你的Broker地址> --topic <目标Topic名> --from-beginning --property print.key=true --property print.value=true
   

   若发现空消息，检查生产者代码是否存在逻辑漏洞导致发送空内容。
4. 升级AKHQ版本：部分旧版AKHQ存在计数逻辑bug，升级到最新稳定版大概率可解决问题。

内容的提问来源于stack exchange，提问作者mpsimham