17 kafka整合springboot和redis实现消息重试机制

文章目录

• 1 kafka实现消息重试
• • 1.1 kafka-retry-quene-common模块说明
  • 1.2 kafka-retry-quene-producer模块说明
  • 1.3 kafka-retry-quene-consumer模块说明
  • 1.4 整合测试
  • • 1.4.1 正常情况测试
    • 1.4.2 生产异常情况测试
    • 1.4.3 消费者异常情况测试

1 kafka实现消息重试

​ 本部分，我们用springboot结合kafka搭建一个生产者消费者应用，并实现在下面三种情况下，消息要重复发送：

​ 1、在发送消息前，系统异常；

​ 2、消息发送到broker过程中，生产者异步确认异常；

​ 3、消费者消费消息异常。

​ 我们先搭建一个项目kafka-retry-quene，在该项目下面有一个生产者项目kafka-retry-quene-producer，消费者项目kafka-retry-quene-consumer，还有一个公共模块kafka-retry