溫馨提示：本文基于 Kafka 2.2.1 版本。 上文 《源碼分析 Kafka 消息發(fā)送流程》 已經(jīng)詳細(xì)介紹了 KafkaProducer s...
投稿
收錄了11篇文章 · 9人關(guān)注
-
KafkaProducer Sender 線程詳解（含詳細(xì)的執(zhí)行流程圖）
-
源碼分析Kafka 消息拉取流程
本節(jié)重點(diǎn)討論 Kafka 的消息拉起流程。 @TOC １、KafkaConsumer poll 詳解 消息拉起主要入口為：KafkaConsum...
-
Kafka 之壓縮算法&Hash算法Kafka 支持的壓縮算法還挺多的，這一篇來站在Kafka的角度看一下壓縮算法。就當(dāng)前情況來說，支持GZIP、Snappy、LZ4 這三種壓縮算...
-
Kafka 交付語義 機(jī)制詳解
上一篇提到了如何利用ISR完成“消息不丟失”，接下來看看如何整體來說，如何實(shí)現(xiàn)Kafka的交付語義。Kafka 或者所有的消息隊(duì)列中都存在的交付...
-
Kafka “高吞吐” 之順序訪問與零拷貝前言 上一篇所說的micr-batch 其實(shí)主要是針對(duì)producer 來實(shí)現(xiàn)的，Kafka整體吞吐量高可不只是依賴于micr-batch這一點(diǎn)...
-
Kafka “高性能” mirc-batch前言 最開始在Kafka 概述中提到了mirc-batch（微批處理），mirc-batch是Kafka 高性能的一個(gè)非常重要的原因，這一下子就...
-
Kafka “不丟消息” ISR LEO&HW解析前言 上一篇介紹的ISR的不丟消息的種種備份及冗余機(jī)制的所有的核心邏輯都是圍繞著HW值、LEO值來展開的，如何合理的更新和存儲(chǔ)顯得尤為重要。 首...
-
Kafka “不丟消息” ISR 機(jī)制解析許多消息都會(huì)各種保證自己的產(chǎn)品不會(huì)丟消息或者消息丟失概率較小，但是靠譜的很少，而且消息隊(duì)列丟消息排查起來是非常麻煩的，所以大多數(shù)在使用的過程中都...
-
Kafka consumer 解析上一篇說了Kafka consumer的處理邏輯、實(shí)現(xiàn)原理及相關(guān)的特點(diǎn)，本篇來看看Kafka 另一個(gè)client Consumer，作為生產(chǎn)者消...
-
Kafka producer 解析前言 Kafka 作為一個(gè)消息系統(tǒng)，其中很大的一個(gè)用途就是作為業(yè)務(wù)上的解耦，而它實(shí)現(xiàn)的模式就是經(jīng)典的生產(chǎn)者消費(fèi)者模式。毫無疑問，就出現(xiàn)了prod...
{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/1800747/timg.jpeg', '推薦專題《Kafka》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/059dac1b259f?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}