Kafka除了具備消息隊(duì)列MQ的特性和使用場景外，它還有一個(gè)重要用途，就是做存儲(chǔ)層。 用kafka做存儲(chǔ)層，為什么呢？一大堆可以做數(shù)據(jù)存儲(chǔ)的 M...
投稿
收錄了6篇文章 · 2人關(guān)注
-
Kafka零拷貝 -
深入解析Kafka消費(fèi)者——提交和偏移量KafkaConsumer(消費(fèi)者)每次調(diào)用 poll()方法，它總是返回由生產(chǎn)者寫入 Kafka但還沒有被消費(fèi)者讀取過的記錄， 我們因 此可以...
-
Kafka消費(fèi)者——從 Kafka讀取數(shù)據(jù)應(yīng)用程序使用 KafkaConsumer向 Kafka 訂閱主題，并從訂閱的主題上接收消息 。 從 Kafka 讀取數(shù)據(jù)不同于從其他悄息系統(tǒng)讀取...
-
Kafka——分區(qū)partition在之前的例子里(Kafka生產(chǎn)者——向 Kafka寫入數(shù)據(jù))， ProducerRecord 對(duì)象包含了目標(biāo)主題、鍵和值。 Kafka 的消息是...
-
Kafka生產(chǎn)者——向 Kafka寫入數(shù)據(jù)不管是把 Kafka 作為消息隊(duì)列、消息、總線還是數(shù)據(jù)存儲(chǔ)平臺(tái)來使用 ，總是需要有一個(gè)可以往 Kafka 寫入數(shù)據(jù)的生產(chǎn)者和一個(gè)可以從 Kafk...
-
《Kafka權(quán)威指南》——初識(shí) Kafka發(fā)布與訂閱消息系統(tǒng) 在正式討論Apache Kafka (以下簡稱Kafka)之前，先來了解發(fā)布與訂閱消息系統(tǒng)的概念， 并認(rèn)識(shí)這個(gè)系統(tǒng)的重要性。...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1651529/logo.png', '推薦專題《Kafka》（ 分享自 @簡書 ）','http://m.itdecent.cn/c/7b5b2d3ba2fe?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}