@KafkaListener 注解本身不创建 MessageListenerContainer，而是由 KafkaListenerAnnotationBeanPostProcessor 扫描注解并封装为 KafkaListenerEndpoint，再交由 KafkaListenerEndpointRegistrar 统一注册、创建容器并启动。
@KafkaListener 注解本身不会自动创建 MessageListenerContainer，它只是声明式标记——真正完成扫描、解析、容器构建和启动的是 Spring Kafka 的基础设施组件。整个过程由 Spring 容器在启动阶段协同完成，核心参与者包括 KafkaListenerAnnotationBeanPostProcessor 和 KafkaListenerEndpointRegistrar。
注解扫描：KafkaListenerAnnotationBeanPostProcessor 起作用
Spring Kafka 在容器初始化时注册一个 BeanPostProcessor 实例：KafkaListenerAnnotationBeanPostProcessor。它会在每个 Bean 初始化后检查是否含有 @KafkaListener 注解：
- 遍历所有已注册的 Bean（包括 @Component、@Service 等托管 Bean）
- 对每个方法级或类级的
@KafkaListener提取元数据（topics、groupId、containerFactory 等） - 将每个有效监听器封装为
KafkaListenerEndpoint对象 - 委托给
KafkaListenerEndpointRegistrar进行统一注册
容器创建：KafkaListenerEndpointRegistrar 统一管理
KafkaListenerEndpointRegistrar 是注册中心，负责收集所有 KafkaListenerEndpoint 并协调容器构建：
- 默认使用
ConcurrentKafkaListenerContainerFactory创建容器（可通过containerFactory属性指定自定义工厂） - 为每个 endpoint 创建独立的
MessageListenerContainer（通常是KafkaMessageListenerContainer） - 容器内部包装用户定义的监听方法为
MethodKafkaListenerEndpoint，并适配为MessageListener或BatchMessageListener - 容器启动时订阅 topic、拉取消息，并在收到消息后反射调用你的监听方法
触发时机：容器上下文刷新完成前启动
所有容器的创建与启动发生在 ContextRefreshedEvent 事件广播之前：
立即学习“Java免费学习笔记（深入）”；
- Spring 完成 Bean 加载、依赖注入、AOP 代理等流程后
-
KafkaListenerEndpointRegistrar调用start()方法批量启动所有容器 - 每个
MessageListenerContainer启动自己的消费者线程（或委托给KafkaConsumer） - 此时你标注了
@KafkaListener的方法才真正开始接收消息
关键配置影响容器行为
以下配置直接决定容器如何构建和运行：
-
@KafkaListener(topics = "my-topic", groupId = "g1")：指定消费主题与组，影响分区分配与 offset 提交策略 -
containerFactory = "myKafkaListenerContainerFactory"：显式指定工厂 Bean，可定制ConsumerFactory、Concurrency、ErrorHandler等 -
@EnableKafka必须出现在配置类上，否则KafkaListenerAnnotationBeanPostProcessor不会被注册 - 若未配置
ConcurrentKafkaListenerContainerFactoryBean，Spring Kafka 会自动提供一个默认工厂（基于DefaultKafkaConsumerFactory）
