有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java这是关于BatchErrorHandler的SpringKafka文档中的错误吗?

我正在阅读Spring documentation关于卡夫卡批量消费中的错误处理

文档建议通过以下方式设置自定义错误处理程序:

@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. # 1 楼答案

    谢谢;这是一个文档错误;固定的它是在不久前从房产搬到工厂的