我们希望配置一个 Spring Kafka 侦听器，以便如果任何外部服务关闭，我们不希望丢失从 Kafka 消费的消息。我们希望将其还原，直到它被成功处理。
你能帮忙配置一下我可以用来实现相同的配置吗？
如果我批量消费消息，我该如何处理。
我们正在使用 Kafka 0.9
1 回答
1
我认为Retry最适合您的要求：
要重试交付，提供了方便的侦听器适配器 -
RetryingMessageListenerAdapter并RetryingAcknowledgingMessageListenerAdapter提供，具体取决于您使用的是 aMessageListener还是AcknowledgingMessageListener.
于 2016-12-27T15:38:39.180 回答