三图搞懂Kafka生产者消息发布模式
点击上方“JavaEdge”，关注公众号
1 同步发送模式源码
2 异步发送模式源码流程
3 总结
3.1 同步发送模式特点
同步的向服务器发送RPC请求进行生产
发送错误可以重试
可以向客户端发送ack
3.2 异步发送模式特点
最终也是通过向服务器发送RPC请求完成的(和同步发送模式一样)
异步发送模式先将一定量消息放入队列中，待达到一-定数量后再一起发送
异步发送模式不支持发送ack,但是Client可以调用回调函数获取发送结果
所以，性能比较高的场景使用异步发送，准确性要求高的场景使用同步发送。
往期推荐
目前交流群已有 800+人，旨在促进技术交流，可关注公众号添加笔者微信邀请进群
喜欢文章，点个“在看、点赞、分享”素质三连支持一下~
评论