5篇文章 · 8662字 · 1人關(guān)注
-
Kafka 常用參數(shù)
replica.lag.time.max.ms ，同時檢測由于慢以及進程卡而導致的滯后（lagging）---即follower副本落后lead...
-
Kafka Consumer
一、consumer特點 consumer不使用zk保存消費位移（offset），而是使用內(nèi)部的消息隊列。因為當數(shù)據(jù)量很大且讀寫頻繁時，ZK的讀...
-
Kafka Producer
一、producer特點 發(fā)送過程涉及兩個線程：用戶主線程和sender I/O線程。 異步發(fā)送消息，提供回調(diào)機制（callback）用于判斷是...
-
MQ消息隊列基礎(chǔ)一、概述 消息隊列中間件是分布式系統(tǒng)中的重要組件，主要實現(xiàn)異步消息，應用解耦，流量削峰和消息通訊等功能。實現(xiàn)高性能，高可用，可伸縮和最終一致性架...
-
Kafka Broker
分區(qū)日志、日志段、日志段索引、日志段時間索引、日志段位移索引、稀疏索引文件 消息設(shè)計 JMM要求Java對象必須按照8字節(jié)對齊，未對齊部分會填充...
