@EnableKafka
时间: 2023-09-30 19:08:52 浏览: 116
@EnableKafka是Spring Boot中的一个注解,用于启用Kafka的自动配置。它可以被用于主应用程序类上,以便自动配置Kafka所需的bean和依赖项。具体来说,@EnableKafka注解会触发KafkaAutoConfiguration类的自动配置过程,该类会根据应用程序的配置和环境设置创建必要的Kafka相关的bean和组件。\[3\]在这个过程中,KafkaListenerEndpointRegistrar类会注册带有@KafkaListener注解的方法,将其转化为KafkaListenerEndpointDescriptor,并将其添加到KafkaListenerEndpointRegistry中。\[1\]\[2\]这样,当应用程序启动时,KafkaListenerEndpointRegistry会创建ConcurrentKafkaMessageContainer实例,用于监听和处理Kafka消息。通过@EnableKafka注解,我们可以方便地启用和配置Kafka的消费者功能。
#### 引用[.reference_title]
- *1* *2* [Kafka架构 - Spring for Apache Kafka - @EnableKafka](https://blog.csdn.net/qq_34561892/article/details/104985872)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
- *3* [Spring Boot应用 @EnableKafka](https://blog.csdn.net/JohinieLi/article/details/128099912)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]