14篇文章 · 34066字 · 8人關(guān)注
-
kafka設(shè)計（下）
6.消息投遞 我們已經(jīng)了解了一些生產(chǎn)者和消費者是如何工作的勇婴，現(xiàn)在讓我們討論在生產(chǎn)者和消費者之間家厌，kafka提供的語義上的保證，顯然kafka提供...
-
kafka設(shè)計（上）
1.動機(jī) kafka被設(shè)計為能扮演一個大公司可能需要的處理所有實時數(shù)據(jù)流的統(tǒng)一平臺痕檬。為了達(dá)成這個目的碴开，我們必須考慮相當(dāng)廣泛的用例。 它必須有很高...
-
13. kafka集群內(nèi)復(fù)制功能深入剖析
kafka是一個分布式發(fā)布訂閱消息系統(tǒng)监右。由LinkedIn開發(fā)并已經(jīng)在2011年7月成為apache頂級項目边灭。kafka在LinkedIn, T...
-
12. kafka壓測：3臺廉價服務(wù)器支撐200萬TPS這篇文章是關(guān)于LinkedIn如何用kafka作為一個中央發(fā)布-訂閱日志，在應(yīng)用程序健盒，流處理绒瘦，hadoop數(shù)據(jù)提取之間集成數(shù)據(jù)。無論如何扣癣，kaf...
-
10. kafka消費者如何分配分區(qū)消費者如何分配分區(qū)就是指某個topic惰帽，其N個分區(qū)和消費該topic的若干消費者群組下M個消費者的關(guān)系。如下圖所示父虑，C0和C1兩個消費者如何分配...
-
9. kafka shell腳本用法詳解
kafka安裝目錄下的bin目錄包含了很多運維可操作的shell腳本该酗，列舉如下： 接下來詳細(xì)說明每個腳本的使用方法。 connect-distr...
-
8. kafka分區(qū)
分區(qū)策略 構(gòu)造KafkaProducer代碼如下： 屬性partitioner.class就是決定消息如何分區(qū)的士嚎，默認(rèn)實現(xiàn)類是DefaultPa...
-
7. kafka序列化&反序列化序列化 kafka序列化消息是在生產(chǎn)端呜魄，序列化后，消息才能網(wǎng)絡(luò)傳輸莱衩。而構(gòu)造KafkaProducer代碼如下： 屬性key.serializer...
-
6. kafka攔截器
攔截器定義攔截器參數(shù)命名為：interceptor.classes爵嗅。官方文檔解析如下： A list of classes to use as ...
