我在这里阅读文档https://docs.spring.io/spring-kafka/docs/2.2.6.RELEASE/reference/html/#retrying-deliveries我无法弄清楚实现的正确方法是什么有批处理侦听器的有状态重试
文档说“没有为批消息侦听器提供重试适配器,因为该框架不知道发生批处理的位置”。
对于我的用例来说,这不是问题,因为我只想重试整个批次。
该文档建议我在侦听器本身中使用RetryTemplate。好的,我可以做到。
问题出现在下一部分,该部分讨论如何使用有状态重试标志在重试之间进行消费者轮询,以防止代理丢弃我的消费者。
如何配置批处理侦听器来做到这一点?批处理侦听器是否支持有状态重试标志?如果“我的重试”逻辑位于侦听器内部,这是否会阻止轮询?statefulRetry标志到底能做什么?
Spring Kafka的最新版本具有特殊的RetryingBatchErrorHandler。https://docs.spring.io/spring-kafka/docs/2.4.6.RELEASE/reference/html/#retrying-batch-eh谢谢,Spring Kafka团队!
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句