大家好,我是好学的小师弟。在kafka-tool出现问题的情况下,我们可以通过命令行来查看kafka的信息。下面是具体的操作步骤:
1. 找到kafka所在的安装目录:
```
find / -name kafka
```
2. 列出有哪些用户组来消费:
```
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.77:9092 --list
```
其中,`bootstrap-server` 是安装kafka的服务器地址。
3. 查看某个用户组的kafka消息消费情况,包括数据积压情况:
```
./kafka-consumer-groups.sh --bootstrap-server 192.168.100.77:9092 --describe --group 用户组名字
```
首先需要查询用户组的ID,可以执行第二条命令。执行后的效果类似于以下格式:
```
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
this is your topic message queue id 0 138 189 51 - - -
```
其中,`CURRENT-OFFSET` 是当前已经消费了的偏移量,`LAG` 是消息积压数量。
4. 查看topic某分区数据偏移量(offset)最大值,即观察目前Kafka里有多少条消息:
```
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.100.77:9092 --topic topic队列名字 --partitions 0
```
将上述命令中的`topic队列名字`替换为实际的队列名称即可。
如果觉得我的回答不错,请给个赞吧!***转载时请注明出处哦!