java - Springboot - Spring Kafka - 惰性容器工厂初始化

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

使用 Spring JDBC 模板,您可以使用简单的标志延迟初始化连接。用于 Springboot 1.5.x/Spring Kafka 1.3.x 部署的 Kafka 容器工厂是否有类似的功能?

到目前为止,我看到的最好的答案是禁用自动启动并自行管理启动,捕获启动期间可能发生的任何异常 - How to start spring application even if Kafka listener (spring-kafka) doesn't initialize

这是唯一的方法吗?使用 KafkaListenerEndpointRegistry self 管理容器的生命周期时有什么注意事项吗?

惰性注释可以与 @KafkaListener、@Kafka 配置类或类似组件类一起使用吗?由于似乎没有记录的处理方法,因此提出这个问题,同时尝试其中一些方法以获得并行反馈。

使用 Springboot 1.5.x 时,Springboot 2.1.x(或更高版本)以及这些版本的兼容 Spring Kafka 版本有何变化(如果有)?

最佳答案

监听器容器的延迟初始化没有意义。什么会触发实例化?

KafkaTemplate 在第一个操作上延迟创建其生产者。

autoStartup 和使用注册表启动/停止是正确的方法。

版本没有区别。

关于java - Springboot - Spring Kafka - 惰性容器工厂初始化,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58600550/

相关文章:

java - 是否可以在java 8流的过滤器方法中执行另一个过程

java - AOP 的不当使用

Java Spring - 仅保存(POST)来自 ManyToOne 关系的 id

java - 我们有专门针对 Spring 5.x 的 XSD 吗?

java - 尝试上传文件,数组有问题

java - 如何修复ORA-01008 : Not all variables bound

java - 用 Java 遍历 Linux/Unix 文件系统?

java - Spring Boot如何管理分布式系统中的bean?

java - 计算Spring Job执行时间

java - 为交错 GridView 动态设置固定高度