消费者组是 Kafka 实现高吞吐量消息消费的核心。
一、消费者组基础
同一组内的多个消费者共享一个 topic 分区数据,实现负载均衡。
二、查看消费者组信息
查看已有组:
bash复制编辑kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
查看某组详细信息:
bash复制编辑kafka-consumer-groups.sh --describe --group my-group --bootstrap-server localhost:9092
三、重置偏移量
将消费位点从头开始:
bash复制编辑kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group my-group --topic test --reset-offsets --to-earliest --execute
重置操作需谨慎,一般用于回溯消费或调试场景。