Spring Kafka 属性 用于设置 SeekToCurrentBatchErrorHandler

Question

是否有spring.kafka属性错误处理批处理

spring.kafka.listener.type=BATCH 和 spring.kafka.listener.ack-mode=BATCH

与 SeekToCurrentBatchErrorHandler？提前致谢。

Answer 1

您不能使用 属性 设置它，但您可以像这样覆盖 Boot 的自动配置容器工厂：

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

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

    factory.setBatchErrorHandler(new SeekToCurrentBatchErrorHandler());

    return factory;
}

它将获取所有引导属性，然后您可以根据需要进一步配置工厂。