我们开始在一个项目中使用 spring-integration-kafka，但找不到任何关于消费者端错误处理建议方法的文档。
理想情况下，我们想要一个不阻塞线程的回退重试策略，因此，似乎无状态重试建议不是一种选择；但是，我找不到在 Kafka 中使用有状态重试建议的示例。
关于我们通常应该如何使用 spring-integration-kafka 处理错误重试的任何建议？谢谢。
最佳答案
请分享有关此事的配置，并指出您希望在何处使用重试建议。
通常任何 inbound-channel-adapter将其消息发送到某个订阅者的 channel ，例如 <service-activator>可以用 RequestHandlerRetryAdvice 配置.
从另一边 <poller>在 <int-kafka:inbound-channel-adapter>可以配置StatefulRetryOperationsInterceptor如你所愿。
关于spring-integration - spring集成kafka错误处理，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29185214/