侦听器的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);
...
}