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 | -

| consumer-1917056618-nmfdv-1547017683649-a56adcd2 | consumerTopic 4 | 98960 | 98960 | 0 | 0 | 98960 | 98960 |