消费者组查询
在 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
? 注:确保消费者组实例处于非活动状态
- kafka-consumer-groups consumer Server groups Kafkakafka-consumer-groups consumer server groups kafka-consumer-groups consumer the group assignment kafka-consumer consumer消息kafka consumer kafka api kafka-consumer consumer kafka go producer consumer kafka3 broker consumer消费者kafka3 kafka kratos kafka group topic