在命令窗口,执行 kafka-consumer-groups.sh 命令可以查看消费者组。

如果不设置消费者组,kafka会自动生成一个默认的消费者组,其名字为:console-consumer-89657

查看消费者组的命令如下所示:

> kafka-consumer-groups.sh \
  --bootstrap-server mykafka01:9092,mykafka02:9092,mykafka03:9092 \
  --list

console-consumer-89657
console-consumer-25399
console-consumer-92059
console-consumer-45548
console-consumer-3458

进一步查看消费情况,可以用describe参数 + 指定消费者组,如下所示:

> kafka-consumer-groups.sh \
  --bootstrap-server mykafka01:9092,mykafka02:9092,mykafka03:9092 \
  --describe \
  --group console-consumer-45548

TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID
cat             2          79668           79668           0               -               -               -
cat             1          79686           79686           0               -               -               -
cat             0          79682           79682           0               -               -