?

?1：消息存儲(chǔ)

segment段中有兩個(gè)核心的文件一個(gè)是log,一個(gè)是index。 當(dāng)log文件等于1G時(shí)，新的會(huì)寫入到下一個(gè)segment中。

? 通過下圖中的數(shù)據(jù)，可以看到一個(gè)segment段差不多會(huì)存儲(chǔ)70萬(wàn)條數(shù)據(jù)。

所以問題這么龐大的數(shù)據(jù)，kafka是如何快速?gòu)暮Ａ繑?shù)據(jù)中定位得到-------基于它的查詢機(jī)制

2：查詢機(jī)制

?

轉(zhuǎn)載于:https://www.cnblogs.com/xlhlx/p/10603976.html

總結(jié)

以上是生活随笔為你收集整理的kafka消息存储原理及查询机制的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。