我如何配置 kafka 批处理消费者使用 SeekToCurrentBatchErrorHandler 重试预定义的次数?

How can i configure a kafka batch consumer to retry a pre-defined no of times using SeekToCurrentBatchErrorHandler?

我正在使用 spring-kafka '2.2.7.RELEASE' 来创建批处理消费者,我正在尝试了解如何配置 kafka 批处理消费者以重试预使用 SeekToCurrentBatchErrorHandler 定义次数?

我看到其中一个 SeekToCurrentErrorHandler 构造函数将 'maxFailures' 作为参数,但我没有看到 SeekToCurrentBatchErrorHandler 有任何此类选项。请提出建议。

2.2.x 不再支持。

请参阅 the documentation 了解批处理侦听器和旧版本框架不支持在一定数量的故障后恢复的原因。

您可以使用 RetryingBatchErrorHandler(自 2.3.7 起)或 RecoveringBatchErrorHandler(自 2.5.0 起)。