我在初始化StreamListener时遇到问题。我不能解决我的问题。
我在我的项目中使用了Spring Cloud Stream Kafka和Spring Cache。Spring Cache在SmartLifeCycle的start()方法之后初始化。但是StreamListener在SmartLifeCycle的start()方法之前就开始消耗数据了。因此,我无法在StreamListener开始使用数据之前完成缓存初始化,这给我带来了问题。
有什么方法可以延迟StreamListener处理或延迟StreamListener bean初始化吗?
发布于 2020-11-21 01:14:01
您可以将绑定的autoStartup设置为false,然后使用BindingsEndpoint bean启动绑定。
参见this answer。
https://stackoverflow.com/questions/64926782
复制相似问题