我看到有些人将 @EnableKafka 添加到他们的 Spring Boot 应用程序中,我想知道为什么。我有一个正在工作的 spring boot kafka 生产者和消费者,但我没有使用@EnableKafka。那么,为什么人们需要显式添加它呢?
谢谢。
最佳答案
这是因为 Spring boot 通过 KafkaAutoConfiguration 类 ( javadoc ) 为 Kafka 提供了自动配置。当您使用 @EnableAutoConfiguration 或 @SpringBootApplication 时,Spring boot 会自动为您配置 Kafka。
您可以通过提供@SpringBootApplication(exclude={KafkaAutoConfiguration.class})
来排除自动配置来进行测试,Spring boot不会自动为您配置Kafka。
如果您不使用 Spring boot,则必须使用 @EnableKafka
为您的 Spring 应用配置 Kafka。
关于java - 在Spring Kafka中,我需要将@EnableKafka注释添加到我的应用程序中吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61256925/