java - 如何通过application.properties激活KafkaBatchListener (factory.setBatchListener(true))

Question

文档清楚地说明了如何设置出厂设置以启用批处理监听器:https://docs.spring.io/spring-kafka/reference/htmlsingle/#batch-listeners

我通过应用程序属性进行所有其他配置:

spring.kafka.bootstrap-servers=url
spring.kafka.listener.ack-mode=record
spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.group-id=id-we
spring.kafka.consumer.max-poll-records=1000
spring.kafka.consumer.value-deserializer=org.meteogroup.kafka.envelope.StringEnvelopeDeserializer

我想避免通过 @Value 参数将所有这些手动移动到代码中。有没有办法通过应用程序属性激活批量监听？

Answer 1

不是通过属性，但您可以简单地覆盖工厂启动的默认自动配置...

@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
        ConcurrentKafkaListenerContainerFactoryConfigurer configurer,
        ConsumerFactory<Object, Object> kafkaConsumerFactory) {

    ConcurrentKafkaListenerContainerFactory<Object, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
    configurer.configure(factory, kafkaConsumerFactory);

    factory.setBatchListener(true);

    return factory;
}