Kafka Server之kafka-consumer-groups.sh

发布时间 2023-10-24 17:48:26作者: eiSouthBoy

消费者组查询

在 kafka server中查看有哪些消费者:./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092

查询到有2个消费者组

消费者组描述

在 kafka server中查看指定消费者组信息:./kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group my-group-62

查询到消费者组:my-group-62,对主题:realtime-topic分区0、分区1进行了消费,且分区0的消息全部消费完成,分区1的消息还有4条等待消费。


在 kafka server中查看指定消费者组状态:./kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group my-group-62 --state


查看另一个消费者组的状态:

消费者组删除

在 kafka server中删除指定消费者组:./kafka-consumer-groups.sh --delete --bootstrap-server localhost:9092 --group hu-ning-62

? 注:仅当消费者组没有任何活动成员时,手动删除才有效

消费者组重置偏移量offset

在 kafka server中重置指定消费者组偏移量(将偏移量重置为最早偏移量):./kafka-consumer-groups.sh --reset-offsets --bootstrap-server localhost:9092 --group my-group-62 --topic realtime-topic --to-earliest

? 注:确保消费者组实例处于非活动状态