kafka的延迟操作-pull操作详解

kafka的延迟操作和正常我们服务端处理事件的方式不一样，我们服务器正常情况下处理数据都是尽可能快的返回当前的结果，但是kafka的延迟操作不一样：
比如生产者发送ack=-1的数据到服务端leader分区所在的主broker上，此时主broker在把消息写入本地文件后要进行等待，此时会创建一个延迟操作，等到其他副本broker同步了该消息并写入对应的日志文件后才会提前触发这个延迟操作的执行，否则需要等待超时时间到了之后再执行.
由此延伸出kafka消息拉消费模式的理解：其实拉的时效性和主动推送是差不多的，原因在于消费端在pull拉取消息的时候，如果当时还没有消息，那么kafka服务端会创建一个拉取的延迟操作，等到有消息写入broker端的时候消息数量满足时，kafka就会把数据返回给消费者,所以这里其实几乎和推送消息是一样的时效性.所以如果消费端是专门用一条线程来pull消息的话，实时性和服务端的主动推送几乎是一样的.

kafka的延迟操作-pull操作详解相关推荐

pdo mysql 绑定查询_php mysql PDO 查询操作的实例详解
php mysql PDO 查询操作的实例详解 php mysql PDO 查询操作的实例详解这篇文章主要介绍了php mysql PDO 查询操作的实例详解的相关资料,希望通过本文能帮助到大家,需 ...
2013河北省职称计算机应用能力考试操作题答案,2013河北省职称计算机应用能力考试操作题步骤详解(部分).doc...
2013河北省职称计算机应用能力考试操作题步骤详解(部分) 2013河北省职称计算机应用能力考试操作题步骤详解PAGE PAGE - 11 - 共 NUMPAGES 11页操作题PPT 1-5PPT操 ...
php mysql PDO 查询操作的实例详解
php mysql PDO 查询操作的实例详解 ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 ...
php node 目录,node.js基于fs模块对系统文件及目录进行读写操作的方法详解
本文主要介绍了node.js基于fs模块对系统文件及目录进行读写操作的方法,结合实例形式分析了nodejs使用fs模块针对文件与目录的读写.创建.删除等相关操作技巧,需要的朋友可以参考下. 如果要用这 ...
MongoDB查询性能分析—— explain 操作返回结果详解
MongoDB 提供 db.collection.explain(), cursort.explain() 及 explain 命令获取查询计划及查询计划执行统计信息. explain 结果将查询计划 ...
2013河北省职称计算机应用能力考试操作题答案,(2013河北省职称计算机应用能力考试操作题步骤详解PPT部分.doc...
(2013河北省职称计算机应用能力考试操作题步骤详解PPT部分操作题PPT 1-5 PPT操作练习一打开PPT文件夹下的"PPT_1.PPT"演示文稿文件,然后进行如下操作: ...
IOS数据库操作SQLite3使用详解(转)
iPhone中支持通过sqlite3来访问iPhone本地的数据库. 具体使用方法如下 1:添加开发包libsqlite3.0.dylib 首先是设置项目文件,在项目中添加iPhone版的sqlite ...
IOS数据库操作SQLite3使用详解
sqlite数据库iosdatabasesqlinteger 目录(?)[+] iPhone中支持通过sqlite3来访问iPhone本地的数据库. 具体使用方法如下 1:添加开发包libsqlite ...
select标签操作 select2使用详解
select标签操作 select2使用详解官网: https://select2.github.io/examples.html 引用: <link href="~/Scripts ...
兄弟机cnc系统面板图解_数控机床操作面板图文详解
<数控机床操作面板图文详解>由会员分享,可在线阅读,更多相关<数控机床操作面板图文详解(53页珍藏版)>请在人人文库网上搜索. 1.数控车床编程和操作(一) 熟 ...

kafka的延迟操作-pull操作详解

kafka的延迟操作-pull操作详解相关推荐

最新文章

热门文章