如何延迟Spring Cloud Stream StreamListener的初始化

Question

我在初始化StreamListener时遇到问题。我解决不了我的问题。

我在我的项目中使用了Spring Cloud Stream Kafka和Spring Cache。Spring Cache是在SmartLifeCycle的start((方法之后初始化的。但是StreamListener在SmartLifeCycle的start((方法之前就开始消耗数据。因此，我无法在StreamListener开始消耗数据之前完成缓存初始化，这给我带来了问题

是否有任何方法可以延迟StreamListener处理或延迟StreamListenerbean初始化？

Answer 1

您可以将绑定的autoStartup设置为false，然后使用BindingsEndpointbean启动绑定。

看看这个答案。