我们开始在项目中使用
spring-integration-kafka,但是找不到任何有关消费者方面的错误处理方法的文档.

理想情况下,我们需要一个不会阻塞线程的退避重试策略,因此,似乎无状态重试建议不是一个选项;但是,我找不到使用Kafka的状态重试建议的示例.

关于我们应该如何使用spring-integration-kafka处理错误重试的任何建议？谢谢. 最佳答案 请分享关于此事的配置,并指出您希望在何处使用重试建议.

通常,任何入站通道适配器都将其消息放入某个通道,其订户类似于< service-activator>可以使用RequestHandlerRetryAdvice进行配置.

从另一侧< poller>在< int-kafka：inbound-channel-adapter>可以根据需要配置StatefulRetryOperationsInterceptor.