java - 在Spring Kafka中,我需要将@EnableKafka注释添加到我的应用程序中吗?

标签 java spring-boot apache-kafka spring-kafka

我看到有些人将 @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/

相关文章:

java - 相互依赖的类之间的冲突通用类型

java - 在没有主机 :port 的情况下通过 JDBC 通过 SID 访问 oracle 数据库

java - Nexus 7 4.2 上的 Android Java 日历日期 WEEK_OF_YEAR 问题

java - 从外部配置文件读取值返回空值

apache-spark - 有没有办法动态停止 Spark Structured Streaming?

java - 寻找最近的2点

java - 如何根据现场可用性注入(inject)应用程序、属性值?

java - 在 Microsoft Azure 的 MSSQL 服务器中创建表时出错 : Spring Boot and Hibernate

node.js - 有没有办法将融合模式注册表与 kafka-node 模块一起使用?

java - 自动缩放工作进程/守护进程作为 Kafka 消费者