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

Question

我正在阅读 Spring documentation 关于 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 调用它，但我没有遇到任何编译问题：这是正确的方法吗？这是文档中的错误吗？

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

Answer 1

谢谢；这是一个文档错误；固定的;前段时间从物业搬到了工厂。