在Spring Kafka中，消费者组是承载消息负载均衡与分组消费的核心设计。其实现逻辑清晰流畅，主要依赖KafkaListenerContainerFactory与ConsumerFactory两大组件。下面从配置细节到实际运行，逐步解析整个消费者组的构建路径。
**第一步：配置KafkaListenerContainerFactory**
这个组件好比消费者组的“生产车间”，负责生成实际的消费者实例。配置时需将ConsumerFactory注入，同时设定并行度——即同时运行的消费者线程数。例如设置setConcurrency(3)，意味着启动3个消费者实例共同分担主题分区压力。具体示例如下：
@Bean
public KafkaListenerContainerFactory kafkaListenerContainerFactory(ConsumerFactory consumerFactory) {
KafkaListenerContainerFactory factory = new KafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory);
factory.setConcurrency(3); // 并发消费者数量
return factory;
} **第二步：配置ConsumerFactory**
该组件负责“制造”真实的Kafka消费者实例，核心配置项包括Kafka集群地址、消费者组ID以及序列化方式。消费者组ID在此处指定——同一组ID下的所有消费者将共享主题分区消息。配置示例如下：
@Bean
public ConsumerFactory consumerFactory() {
Map props = new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
return new DefaultKafkaConsumerFactory<>(props);
} 其中bootstrapServers指向Kafka集群的地址，groupId便是消费者组ID——所有属于该组的消费者都会通过这个标识被识别并归入同一消费组。
**第三步：创建Kafka消费者监听器**
有了工厂和配置后，需要编写一个监听器来订阅具体主题。通过@KafkaListener注解，指定待消费的主题及所属组ID。监听器方法会收到每条消息记录的键、值、分区和偏移量等元数据。示例代码如下：
@Service
public class KafkaConsumerListener {
@KafkaListener(topics = "${kafka.topic}", groupId = "${kafka.groupId}")
public void listen(ConsumerRecord record) {
System.out.printf("Received message: key = %s, value = %s, partition = %d, offset = %d%n",
record.key(), record.value(), record.partition(), record.offset());
}
} 这里的kafka.topic和kafka.groupId为配置属性，可通过配置文件灵活设定，便于不同环境切换。
**第四步：启动应用程序**
完成上述配置后，启动Spring Boot应用即可。Spring Kafka会根据设定的并发数自动创建对应数量的消费者实例。这些实例依据组ID与Kafka集群自动协商，完成各自负责的分区分配。整个过程无需额外人工干预，组内成员间的负载均衡完全由Kafka的组协调机制接管。
从实践角度来看，这套流程将Spring框架的自动配置能力与Kafka的分布式消费协议无缝对接。只要按步骤配置好工厂、消费者及监听器，消费者组的搭建即可顺理成章地完成。
