Kafka - 延迟绑定直到复杂的服务初始化完成
Kafka - Delay binding until complex service initialisation has completed
我正在使用 Spring Cloud Stream Kafka，但我有一个特定的服务具有复杂的启动依赖性（long-运行），它可能相当脆弱，所以我想延迟 Kafka（消费者）绑定，直到确认初始化成功。
我怎样才能做到这一点？
目前 Spring Cloud Stream 无法实现；您可以直接使用 Spring Kafka（例如 @KafkaListener）并将容器工厂的 autoStartup 设置为 false 来完成。或者使用 Spring Integration Kafka 并对入站通道适配器执行相同的操作。
您可以使用 Spring Cloud Stream 将 @StreamListener 加载到子引导应用程序而不是主应用程序中。
我正在使用 Spring Cloud Stream Kafka，但我有一个特定的服务具有复杂的启动依赖性（long-运行），它可能相当脆弱，所以我想延迟 Kafka（消费者）绑定，直到确认初始化成功。
我怎样才能做到这一点？
目前 Spring Cloud Stream 无法实现；您可以直接使用 Spring Kafka（例如 @KafkaListener）并将容器工厂的 autoStartup 设置为 false 来完成。或者使用 Spring Integration Kafka 并对入站通道适配器执行相同的操作。
您可以使用 Spring Cloud Stream 将 @StreamListener 加载到子引导应用程序而不是主应用程序中。