尧图网络 高端网站定制 · 原创设计
免费咨询热线
400-888-6620
免费获取方案
Kafka架构 数据发送保障
producer是如何确定分区已经成功的将这条消息保存起来了其实就是produce发送消息leader收到这条消息并且成功的保存下来了那么会给producer回复叫做ACKproducer在收到了这样回复之后就认为分区把消息成功保存下来了。如果producer没有收到这样的消息那么producer会重复的发送这条消息再次发送直到收到为止。这就是kafka中发送数据的保障。leader在将消息存储到本地之后follower需要向leader做消息的同步副本的同步方式有下面两种策略。kafka采用的是第二种策略当所有的follower同步完成之后才会发送ACK给producer。第一个策略当中副本的数量是有要求的。第二个策略当中但凡有一个follower没有同步完成这个时候leader就得一直等下去直到同步完成才会给producer发ack。这样是不行的不能让leader死等下去。leader维护了一个动态的列表副本同步队列也就是有哪些follower可以和leader建立联系。这样follower就会存在ISR队列里面在一个主题描述信息查看的时候可以看到leader和follower的结合也就是哪些follower可以和leader建立联系这样的follower就会存在于ISR队列当中。当ISR中的follower完成数据的同步之后leader就就会给producer发送ack应答。如果follower长时间没有和leader进行同步那么也不会死等下去了会将follower踢出isr的队列当剩下的follower将数据同步完成leader就可以向producer发送ack了。同样当leader发生故障之后就会从ISR列表中当中选举一个新的leader出来。这就是Kafka当中消息保障的机制。kafka为了保证数据可以成功的写入分区当中会有一个ack的应答机制。1 不需要等待副本的同步leader只要将消息写下来了就会返回ackproducer就可以发送下一条消息了。
RELATED

相关推荐

lark-cli 邮件模板创建:`mail +template-create` 完整实战指南

lark-cli 邮件模板创建:`mail +template-create` 完整实战指南

lark-cli 邮件模板创建:mail template-create 完整实战指南 【免费下载链接】cli The official Lark/飞书 CLI tool, maintained by the larksuite team — built for humans and AI Agents. Covers core business domains including Messenger, Docs, Base, Sheets…

📅 2026/9/22 18:45:51
2026最新移动观象台面试避坑指南:3个底层逻辑助你通关

2026最新移动观象台面试避坑指南:3个底层逻辑助你通关

2026最新移动观象台面试避坑指南:3个底层逻辑助你通关 版本升级后 API 全变了,代码刚跑通就报 404?这是 2026…

📅 2026/9/22 18:45:51
3个必踩坑:中国山脉图渲染源码解析与避坑指南

3个必踩坑:中国山脉图渲染源码解析与避坑指南

3个必踩坑:中国山脉图渲染源码解析与避坑指南 上周陪朋友去面试,对方是某大型测绘数据公司的技术负责人。面试中途,朋友自信满满地展示了一个基于Python和Matplotlib绘制的中国地形可视化项目。面试官没问算法,只问了一句:“你的中国山…

📅 2026/9/22 18:45:51
MORE NEWS

更多资讯

📰

搞定百度地图生成器:3个高频面试题拆解底层逻辑

搞定百度地图生成器:3个高频面试题拆解底层逻辑 上周帮一个做物流调度系统的兄弟调Bug,他抓着头发问我:“为啥我调百度地图API生成轨迹,有时候返回的数据里,经纬度顺序是反的?还有这个 status…

📰

目标职业实战项目避坑:3个底层逻辑搞定代码调试

目标职业实战项目避坑:3个底层逻辑搞定代码调试 刚接手一个 实战项目 ,从 GitHub 或 CSDN 复制了一段核心逻辑代码,满怀期待地跑起来,结果控制台红字一片。报错信息 IndexError: list index out of…

📰

撩妹聊天记录解析:3种方案面试必问对比

撩妹聊天记录解析:3种方案面试必问对比 官方文档堆砌术语,新手看晕眼。 面试必问数据处理,你只背八股文? 3种解析方案,代码跑通即拿分。 定位:三种技术路线的底层逻辑差异 聊到 撩妹聊天记录…

📰

3招搞定HIZ性能瓶颈:从入门到精通的实战指南

3招搞定HIZ性能瓶颈:从入门到精通的实战指南 官方文档翻了三遍,代码跑起来还是卡?别急,HIZ(Hyperscale Index…

📰

5个实战技巧: 攻克开创ERP性能瓶颈源码解析

5个实战技巧: 攻克开创ERP性能瓶颈源码解析 版本升级后 API 全变了?别急着崩溃。很多老哥在接手【开创ERP】二次开发或系统迁移时,第一反应就是骂娘:怎么连个查询接口都换了写法,旧代码跑起来慢得像蜗牛。这时候光看报错没用,你得沉下心去…

📰

黄继鹏认证避坑指南:3个致命错误导致白花钱,附补救代码

黄继鹏认证避坑指南:3个致命错误导致白花钱,附补救代码 官方文档那几百页根本没人看得完,尤其是刚入行的培训机构学员,盯着PDF发呆半小时还是不知道下一步点哪里。别慌,这份 避坑指南…

TODAY

今日更新

THIS WEEK

本周精选

THIS MONTH

本月热门

读完文章,想聊聊您的网站?

告诉我们您的行业与需求,资深顾问一对一梳理方案与报价,全程免费。

📞 💬