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;
}

Она получит все свойства загрузки, и затем вы сможете дополнительно настроить фабрику по мере необходимости.