降級(jí)與熔斷 1.1、降級(jí) 降級(jí)也就是服務(wù)降級(jí),當(dāng)我們的服務(wù)器壓力劇增,為了保證核心功能的可用性,可以選擇性的降低一些功能的可用性,或者直接關(guān)閉該...
1、過期時(shí)間(TTL) 通過消息的timestamp字段和ConsumerInterface接口的onConsumer()方法可實(shí)現(xiàn)消息的TTL...
1、文件目錄布局 不考慮多副本的情況,一個(gè)分區(qū)對(duì)應(yīng)一個(gè)日志(log)。為了防止log過大,Kafka還引入了日志分段(LogSegment)的概...
主題作為消息的歸類,可以再細(xì)分為一個(gè)或多個(gè)分區(qū),分區(qū)可以看作對(duì)消息的二級(jí)歸類。分區(qū)的劃分不僅為Kafka提供了可伸縮性、水平擴(kuò)展的功能,還通過多...
http://www.itdecent.cn/p/aa0d4808cbb8 1、底層數(shù)據(jù)結(jié)構(gòu) hashmap的定義位于src/runtim...
1、消費(fèi)者和消費(fèi)者組 消費(fèi)者負(fù)責(zé)訂閱Kafka中的主題,并從訂閱的主題中拉取消息。與其他消息中間件不同的是:Kafka中的消費(fèi)理念中還有一層消費(fèi)...
1、客戶端開發(fā) 下面是構(gòu)造的消息對(duì)象ProducerRecord. public class ProducerRecord<K,V>( p...
前言:切片的設(shè)計(jì)思想來源于動(dòng)態(tài)數(shù)組,是為了開發(fā)者能更加方便地使用使一個(gè)數(shù)據(jù)結(jié)構(gòu)能自動(dòng)增加和減少,但是切片本身并不是動(dòng)態(tài)數(shù)組。 1、切片與數(shù)組 G...
前言: Kafka雖然是基于磁盤做的數(shù)據(jù)存儲(chǔ),但卻具有高性能、高吞吐、低延時(shí)的特點(diǎn),其吞吐量動(dòng)輒幾萬、幾十上百萬。總結(jié)起來大致就5個(gè)原因,順序讀...