afka消费情况查看
不同的Kafka版本可能需要使用不同的命令来查看消费情况,下面分别介绍三种常见的运行方式及对应的结果展示:
## 1. 运行命令一
在执行命令前,首先需要找到Kafka的运行路径。假设已经知道Kafka的安装路径为`/path/to/kafka`,则可以使用以下命令查看消费情况(以消费者组名为`groupName`,主题名为`topicName`为例):
```shell
/path/to/kafka/bin/kafka-consumer-groups --zookeeper localhost:2181 --describe --group groupName
```
运行后,将输出类似如下的结果:
```yaml
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
groupName topicName partitionId beginOffset endOffset lag consumer host clientId
```
其中,每一行代表一个分区的情况,包括当前偏移量(`CURRENT-OFFSET`)、日志结束偏移量(`LOG-END-OFFSET`)、消费滞后(`LAG`)等信息。
## 2. 运行命令二
使用以下命令可以查看指定消费者组和主题的消费情况:
```shell
/path/to/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group ** --topic ** --zookeeper *:2181,*:2181,*:2181/kafka --zookeeper
```
请将其中的 `**` 替换为实际的参数值,例如:
```shell
/path/to/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group myGroup --topic myTopic --zookeeper localhost:2181,localhost:9092,localhost:9093/kafka --zookeeper
```
运行后,将输出类似如下的结果(以消费者组名为`myGroup`,主题名为`myTopic`为例):
```yaml
{"version":1,"partitions":[{"topic":"myTopic","partition":0,"errorCode":null}]}
```
上述结果表示成功获取到了分区 0 的信息。如果存在错误码(`errorCode`不为空),则表示获取失败。
## 3. 运行命令三
使用以下命令可以查看指定消费者组和主题的消费情况:
```shell
/path/to/kafka/bin/kafka-consumer-offset-checker.sh --zookeeper localhost:2181 --group group_id --topic topic_name
```
同样地,请将其中的 `**` 替换为实际的参数值,例如:
```shell
/path/to/kafka/bin/kafka-consumer-offset-checker.sh --zookeeper localhost:2181 --group myGroup --topic myTopic --zookeeper localhost:2181,localhost:9092,localhost:9093/kafka --zookeeper
```
消费者组 | TOPIC | PID | OFFSET | LOGSIZE | LAG | 当前已消费的条数 | 总条数 | 未消费的条数 |
|------------------|-----------------------|-----------------|-------------------|----------------------|--------------------|---------------|------|----------|
| consumer-1917056618-nmfdv-1547017683649-a56adcd2 | consumerTopic 0 | 145549 0 | 145549 | 0 | 0 | 145549 | 145549 | -
| consumer-1917056618-nmfdv-1547017683649-a56adcd2 | consumerTopic 1 | 296494 0 | 296494 | 0 | 0 | 296494 | 296494 | -
| consumer-1917056618-nmfdv-1547017683649-a56adcd2 | consumerTopic 2 | 363063 0 | 363063 | 0 | 0 | 363063 | 363063 | -
| consumer-1917056618-nmfdv-1547017683649-a56adcd2 | consumerTopic 3 | 84299 | 84299 | 0 | 0 | 84299 | 84299 | -