
Kafka 支持的壓縮算法還挺多的茬贵,這一篇來站在Kafka的角度看一下壓縮算法。就當(dāng)前情況來說沼头,支持GZIP爷绘、Snappy、LZ4 這三種壓縮算...
上一篇提到了如何利用ISR完成“消息不丟失”进倍,接下來看看如何整體來說土至,如何實(shí)現(xiàn)Kafka的交付語義。Kafka 或者所有的消息隊(duì)列中都存在的交付...
前言 上一篇所說的micr-batch 其實(shí)主要是針對(duì)producer 來實(shí)現(xiàn)的猾昆,Kafka整體吞吐量高可不只是依賴于micr-batch這一點(diǎn)...
前言 最開始在Kafka 概述中提到了mirc-batch(微批處理)陶因,mirc-batch是Kafka 高性能的一個(gè)非常重要的原因,這一下子就...
前言 上一篇介紹的ISR的不丟消息的種種備份及冗余機(jī)制的所有的核心邏輯都是圍繞著HW值垂蜗、LEO值來展開的楷扬,如何合理的更新和存儲(chǔ)顯得尤為重要解幽。 首...
許多消息都會(huì)各種保證自己的產(chǎn)品不會(huì)丟消息或者消息丟失概率較小,但是靠譜的很少烘苹,而且消息隊(duì)列丟消息排查起來是非常麻煩的躲株,所以大多數(shù)在使用的過程中都...
上一篇說了Kafka consumer的處理邏輯、實(shí)現(xiàn)原理及相關(guān)的特點(diǎn)镣衡,本篇來看看Kafka 另一個(gè)client Consumer霜定,作為生產(chǎn)者消...
前言 Kafka 作為一個(gè)消息系統(tǒng),其中很大的一個(gè)用途就是作為業(yè)務(wù)上的解耦廊鸥,而它實(shí)現(xiàn)的模式就是經(jīng)典的生產(chǎn)者消費(fèi)者模式望浩。毫無疑問,就出現(xiàn)了prod...
接觸Kafka之前需要首先理解幾個(gè)概念惰说。 0曾雕、分布式系統(tǒng) 比較常見的概念:建立在計(jì)算機(jī)網(wǎng)絡(luò)之上的軟件系統(tǒng),若干獨(dú)立計(jì)算機(jī)的集合助被,這計(jì)算機(jī)對(duì)用戶來...