消费者组是 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

重置操作需谨慎,一般用于回溯消费或调试场景。

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注