gpt4 book ai didi

spring-boot - Spring 卡夫卡消费者重试

转载 作者:行者123 更新时间:2023-12-04 03:36:05 32 4
gpt4 key购买 nike

我正在使用 Spring Kafka 消费者,它从主题中获取消息并将它们保存到数据库中。如果满足失败条件,例如数据库不可用,kafka 消费者库是否提供重试机制?如果是这样,有没有办法设置不同的重试间隔,例如第一次重试应该在 5 分钟后进行,第二次在 30 分钟后进行,第三次在 1 小时后进行等。

最佳答案

Spring Kafka 随附 RetryingMessageListenerAdapterRetryingAcknowledgingMessageListenerAdapter .如果您使用 @KafkaListener ,可以提供AbstractKafkaListenerContainerFactoryRetryTemplate .最后一个可以注入(inject)任意自定义RetryPolicyBackOffPolicy来自 Spring Retry 项目:

https://docs.spring.io/spring-kafka/reference/html/#retrying-deliveries

还要记住,自从版本 2.0 ,Spring Kafka 中有事务支持,基于 Apache Kafka 0.11.x.x 中的这样一个:

https://docs.spring.io/spring-kafka/reference/html/#transactions

关于spring-boot - Spring 卡夫卡消费者重试,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46532116/

32 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com