spring-kafka - 如何配置 kafka 批处理使用者以使用 SeekToCurrentBatchErrorHandler 重试预定义的次数？

Question

我正在使用 spring-kafka '2.2.7.RELEASE' 创建批处理使用者，我试图了解如何配置 kafka 批处理使用者以使用 SeekToCurrentBatchErrorHandler 重试预定义的次数？

我看到 SeekToCurrentErrorHandler 构造函数之一将“maxFailures”作为参数，但我没有看到 SeekToCurrentBatchErrorHandler 的任何此类选项。请建议。

标签： spring-kafka

Answer 1

不再支持 2.2.x。

有关批处理侦听器和较旧版本的框架不支持在一些故障后恢复的原因，请参阅文档。

您可以改用RetryingBatchErrorHandler（自 2.3.7 起）或RecoveringBatchErrorHandler（自 2.5.0 起）。