Spring Kafka Consumer Retry

Question

我正在使用Spring Kafka使用者从主题中获取消息并将其持久保存到数据库中.如果满足失败条件,比如说db不可用,kafka使用者库是否提供重试机制？如果是,有没有办法设置不同的重试间隔,如第一次重试应在5分钟后完成,第二次在30分钟后完成,第3次在1小时后等.

Answer 1

Spring Kafka随附RetryingMessageListenerAdapter和RetryingAcknowledgingMessageListenerAdapter.如果你使用@KafkaListener,你可以提供AbstractKafkaListenerContainerFactory用RetryTemplate.最后一个可以注入任何自定义RetryPolicy和BackOffPolicySpring Retry项目:

https://docs.spring.io/spring-kafka/docs/2.0.0.RELEASE/reference/html/_reference.html#_retrying_deliveries

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

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