如果存在servicedown异常，kafkamessagelistenercontainer将重新处理消息

rsl1atfo 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(322)

我们希望将springkafka侦听器配置为这样一种方式：如果任何外部服务关闭，我们就不希望丢失kafka使用的消息。我们希望在成功处理之前还原它。
请你帮我配置一下，我可以用它来实现同样的效果。
如果我成批使用消息，我该如何处理它。
我们用的是Kafka0.9

spring apache-kafka spring-kafka

来源：https://stackoverflow.com/questions/41346179/kafkamessagelistenercontainer-reprocess-a-message-if-there-is-servicedown-except

1条答案

按热度按时间

xzlaal3s1#

我认为这最符合你的要求：
要重试传递，请使用方便的侦听器适配器- RetryingMessageListenerAdapter 以及 RetryingAcknowledgingMessageListenerAdapter 根据您是否使用 MessageListener 或者一个 AcknowledgingMessageListener .

赞(0）回复(0）举报 2021-06-07

我来回答

如果存在servicedown异常，kafkamessagelistenercontainer将重新处理消息

1条答案

相关问题

热门标签

最新问答