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 楼答案
谢谢;这是一个文档错误;固定的它是在不久前从房产搬到工厂的