- 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 消费者异常情况测试
本部分，我们用springboot结合kafka搭建一个生产者消费者应用，并实现在下面三种情况下，消息要重复发送：
1、在发送消息前，系统异常；
2、消息发送到broker过程中，生产者异步确认异常；
3、消费者消费消息异常。
我们先搭建一个项目kafka-retry-quene，在该项目下面有一个生产者项目kafka-retry-quene-producer，消费者项目kafka-retry-quene-consumer，还有一个公共模块kafka-retry
