在Apache Kafka中，作为一款分布式流处理平台，其核心组件包括生产者、消费者以及存储消息的主题。对于运维人员和开发者来说，熟练掌握Kafka的一些基本命令行工具对日常的监控与故障排查至关重要。本文将详细介绍Kafka中常用的查看主题以及消费数据的排查命令。

一、查看主题列表

在Kafka中，我们可以使用`kafka-topics.sh`脚本来查看当前集群中的所有主题：

```bash
bin/kafka-topics.sh --list --zookeeper localhost:2181
```
或者在新版Kafka 0.9以后，由于Zookeeper的作用逐渐被Kafka自身的服务发现机制取代，因此可以改为：

```bash
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
```

二、查看主题详情

要查看特定主题的详细信息，如分区数量、副本数量等，可以使用以下命令：

```bash
bin/kafka-topics.sh --describe --topic <topic_name> --bootstrap-server localhost:9092
```

三、查看主题分区的最新偏移量

了解主题分区的最新消息偏移量有助于我们判断是否有消息积压或消费延迟等问题，通过如下命令获取：

```bash
bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
--broker-list localhost:9092 \
--topic <topic_name> \
--time -1
```
这里的`-1`代表获取最新的偏移量。

四、查看消费者组信息及消费情况

Kafka从0.9版本开始引入了消费者组的概念，通过`kafka-consumer-groups.sh`命令可以查看消费者组的相关信息：

1. 查看消费者组列表：

```bash
bin/kafka-consumer-groups.sh --new-consumer --list --bootstrap-server localhost:9092
```

2. 查看消费者组的消费详情：

```bash
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group <consumer_group_id> \
--describe
```
此命令会显示消费者组正在消费哪些主题、各个分区的消费位点（当前消费到的消息偏移量）、已提交的消费位点以及滞后消息的数量等关键信息。

总结来说，Kafka提供的这些命令行工具极大地便利了我们对主题和消费数据的管理和排查工作，帮助我们实时监控系统状态，快速定位问题，确保消息系统的稳定运行。同时，针对具体的业务场景和需求，我们还可以结合日志分析、性能监控等手段，更深入地进行问题诊断和优化。

《行业指标体系白皮书》下载地址：https://www.dtstack.com/resources/1057/?src=bbs

《数据治理行业实践白皮书》下载地址：https://www.dtstack.com/resources/1001/?src=bbs

《数栈V6.0产品白皮书》下载地址：https://www.dtstack.com/resources/1004/?src=bbs

想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友，浏览袋鼠云官网：https://www.dtstack.com/?src=bbs

同时，欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」，交流最新开源技术信息，群号码：30537511，项目地址：https://github.com/DTStack