java - 这是关于 BatchErrorHandler 的 Spring-Kafka 文档中的错误吗？

Question

我正在阅读有关 kafka 批处理中的错误处理的Spring 文档。

该文档建议以这种方式设置自定义错误处理程序：

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

但从 2.2.xsetBatchErrorHandler开始不适用于ContainerProperties.

我尝试直接从 中调用它ConcurrentKafkaListenerContainerFactory并且我没有任何编译问题：这是正确的方法吗？这是文档中的错误吗？

非常感谢。希望这对 Spring 社区有所帮助。

标签： javaerror-handlingspring-kafka

Answer 1

谢谢; 这是一个文档错误；固定的; 不久前，它从物业搬到了工厂。