KafkaMessageListenerContainer 如果出现 servicedown 异常，则重新处理消息

Question

我们希望配置一个 Spring Kafka 侦听器，以便在任何外部服务出现故障时我们不希望丢失从 Kafka 消费的消息。我们希望将其还原，直到成功处理为止。

请您帮忙配置一下，我可以用来实现同样的效果。

如果我批量消费消息，如何处理。

我们使用的是 Kafka 0.9

Answer 1

我认为Retry 最符合您的要求：

要重试交付，提供了方便的侦听器适配器 - RetryingMessageListenerAdapter 和 RetryingAcknowledgingMessageListenerAdapter，具体取决于您使用的是 MessageListener 还是 AcknowledgingMessageListener。