Это ошибка в документации Spring-Kafka о BatchErrorHandler? - PullRequest
Новая
       14

Это ошибка в документации Spring-Kafka о BatchErrorHandler?

0 голосов
/ 03 мая 2019

Я читаю Документация Spring об обработке ошибок в пакетном режиме kafka.

Документ предлагает настроить собственный обработчик ошибок следующим образом: 

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>>
        kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<Integer, String> factory =
            new ConcurrentKafkaListenerContainerFactory<>();
    ...
    factory.getContainerProperties().setBatchErrorHandler(myBatchErrorHandler);
    ...
    return factory;
}

, но с 2.2.x setBatchErrorHandler не применимо к ContainerProperties.

Я пытался вызвать его напрямую из ConcurrentKafkaListenerContainerFactory, и у меня нет проблем с компиляцией: это правильный путь? Это ошибка в документации?

Большое спасибо. Надеюсь, это поможет Весеннему Сообществу.

1 Ответ

1 голос
/ 03 мая 2019

Спасибо;это ошибка документации;фиксированный;некоторое время назад оно было перенесено из собственности на завод.

...