建站
咨詢
售后
建站咨詢
新聞中心
這篇文章主要講解了“Kakfa的原理和使用方法”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“Kakfa的原理和使用方法”吧！
創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括靜海網(wǎng)站建設(shè)、靜海網(wǎng)站制作、靜海網(wǎng)頁(yè)制作以及靜海網(wǎng)絡(luò)營(yíng)銷策劃等。多年來(lái)，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，靜海網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到靜海省份的部分城市，未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
kafka是一種分布式的、基于發(fā)布/訂閱的消息系統(tǒng)
1、kafka隊(duì)列為什么吞吐量大
a、生產(chǎn)消息時(shí)kafka是順序?qū)懭胗脖P
b、Kafka的數(shù)據(jù)并不是實(shí)時(shí)的寫入硬盤而是使用內(nèi)存映射文件技術(shù)（mmap）
Kafka提供了一個(gè)參數(shù)——producer.type來(lái)控制是不是主動(dòng)flush 即同步和異步
c、消費(fèi)者消費(fèi)消息時(shí)讀取數(shù)據(jù)的時(shí)候是以文件的方式零拷貝從內(nèi)核空間直接輸入到端口上
d、Kafaka消息存儲(chǔ)是基于partiton，可以橫行擴(kuò)展
2、kafaka Broker Server
leader選舉
防止kafka丟消息
1、生產(chǎn)端使用同步發(fā)送、設(shè)置required.acks屬性為-1（主從同時(shí)確認(rèn)）
0：不確認(rèn)，1：主確認(rèn)
2、設(shè)置消息ID保證消息不重復(fù)
3、消費(fèi)端設(shè)置delivery屬性為at least one 至少消費(fèi)一次
先消費(fèi)再確認(rèn)。通過(guò)業(yè)務(wù)主鍵保證冪等
感謝各位的閱讀，以上就是“Kakfa的原理和使用方法”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)Kakfa的原理和使用方法這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！
網(wǎng)頁(yè)標(biāo)題：Kakfa的原理和使用方法
文章鏈接：http://www.dlmjj.cn/article/pggjsh.html
