Kafka生产者之重试机制
假如我们的kafka集群可能有一些网络问题，这个时候 producer写数据的时候可能会出现一些问题，那么kafka内部就会有失败重试机制，但是面临了两个问题1. 消息乱序
有的时候一些leader切换的时候，需要进行重试，设置
retries即可，但是消息重试会导致重复发送的问题，比如说网络抖动导致producer以为没成功，其实是成功了的，这个时候就会出现消息重复的问题2. 消息乱序
消息重试是可能会导致消息乱序的，因为可能排在你后面的消息都发送出去了，所以可以使用
“max.in.flight.requests.per.connection”的参数设置为1，这样可以保证producer同一时间只能发送一条消息3. 重试间隔
【Kafka生产者之重试机制】重试间隔默认是100ms，用
“retry.backoff.ms” 300ms差不多了推荐阅读
- PMSJ寻平面设计师之现代(Hyundai）
- 太平之莲
- 闲杂“细雨”
- 七年之痒之后
- 深入理解Go之generate
- 由浅入深理解AOP
- 期刊|期刊 | 国内核心期刊之（北大核心）
- 生活随笔｜好天气下的意外之喜
- 感恩之旅第75天
- python学习之|python学习之 实现QQ自动发送消息