java - 在 Spring Kafka 中，我是否需要将 @EnableKafka 注释添加到我的应用程序中？

Question

我看到有些人在他们的 Spring Boot 应用程序中添加了@EnableKafka，我想知道为什么。我有一个工作的 spring boot kafka 生产者和消费者，我没有使用@EnableKafka。那么，为什么人们需要明确添加呢？

谢谢你。

标签： javaspring-bootapache-kafkaspring-kafka

Answer 1

KafkaAutoConfiguration这是因为 Spring boot 通过类（javadoc）为 Kafka 提供了自动配置。当你使用@EnableAutoConfigurationor@SpringBootApplication时，Spring boot 会自动为你配置 Kafka。

您可以通过提供排除自动配置来测试它@SpringBootApplication(exclude={KafkaAutoConfiguration.class})，Spring boot 不会自动为您配置 Kafka。

如果您不使用 Spring boot，那么您将不得不@EnableKafka为您的 Spring 应用程序配置 Kafka。