公开侦听器属性以控制所有容器工厂上所有侦听器的自动启动



侦听器的autoStartup属性当前在ContainerProperties以及KafkaListener注释级别上公开。

在某些情况下,在配置级别为所有工厂中的所有侦听器设置此属性可能会很有趣。

那么,在KafkaProperties#Listener级别公开这个属性难道没有意义吗。

提案:spring.kafka.listener.au启动

从一般的角度来看,并不总是清楚为什么一些ContainerProperties在spring.kafka.elistener.*下公开,而其他的则不公开。将它们全部公开(至少是我们可以从属性文件中设置的内容,如syncCommits、syncCommitTimeout、deliveryAttemptHeader、pauseImmediate等(不是更有意义吗?

我可以为这个功能做出贡献。其想法是统一设置容器属性的方式。

任何反馈都非常受欢迎。

自动配置由spring-boot执行,而不是像spring-kafka这样的单个项目。您需要在那里提交您提出的更改。

通过将工厂注入其他bean定义工厂方法,您可以轻松地为所有侦听器配置它:

@Bean
SomeBean someBean(ConcurrentKafkaListenerContainerFactory<?, ?> factory) {
factory.setAutoStartup(false);
...
}

最新更新