spring kafka错误处理和重试

Question

嗨，我们正在使用 Spring kafka 1.3.3，我们的应用程序是消费 - 流程 - 发布管道。

如果管道在生产阶段出现任何故障，我们如何处理重试和回溯。例如：应用程序正在消费消息，处理它们并以异步方式发布到另一个主题。但是如果发布有任何错误

1. 如何重试发布失败的消息。

2. 如果重试后消息发送失败，我如何才能将我的消费者找回到之前的偏移量？因为到那时我的消费者位置将在日志中领先。

3. 消息生产成功后如何在生产者回调中确认消息。

Answer 1

较新版本更容易，因为您可以直接访问Consumer，但在 1.3.x 中，您可以实现ConsumerSeekAware - 请参阅the documentation。您必须在侦听器线程上执行搜索，因为 Consumer 不是线程安全的。