如何查找Apache Kafka实例中存有数据的Topic？

不需要额外安装工具，用Kafka自带的原生命令就能实现，全程不会读取消息内容、不会统计全量消息条数，对集群几乎无负载，结果准确。

• 核心判断逻辑：对任意Topic，只要存在至少一个分区的最新偏移量 - 最早偏移量 > 0，就说明该Topic当前存有留存数据；如果所有分区的两个偏移量差值为0，说明Topic是空的（要么从未写入过数据，要么历史数据已经过了留存期被全量删除）。
• 操作步骤：
  1. 先查询所有Topic各分区的最早偏移量（即当前留存的第一条消息的位置），执行命令：
     kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <替换为你的Kafka broker连接地址，多个地址用逗号分隔> --time -2
  2. 再查询所有Topic各分区的最新偏移量（即下一条要写入的消息的位置），执行命令：
     kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <和上面填的broker地址一致> --time -1
  3. 逐Topic逐分区计算两个偏移量的差值，只要有一个分区差值大于0，就标记为有数据的Topic即可。
• 适配特殊场景：如果你的集群开了SASL/SSL认证，只需要在上面两条命令末尾加上--command-config <你的客户端认证配置文件路径>就行，配置文件写法和你平时用Kafka其他命令行工具的认证配置完全一致，不需要额外调整。

避坑提醒：不要靠「Topic存在」「分区数正常」就判定Topic有数据，Topic元数据会长期留存，但数据到了设置的留存时间会被自动删除，只看元数据会出现大量误判。

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