TJ_yyy

1 浸赫、消息發(fā)送方法：Producer.send(new ProducerRecord()) 2 、Producer 生產(chǎn)者對(duì)象瘾蛋，這個(gè)對(duì)象是線程安全的，所以可以在多線程下用來發(fā)...

TJ_yyy

（）1序列化(key.serializer 和 value.serializer 參數(shù)設(shè)置哺哼，和自定義序列化器) kafka 自帶String佩抹、Double、Integer取董、L...

TJ_yyy

1生產(chǎn)者發(fā)送消息到broker 需要經(jīng)過攔截器棍苹，序列化器，分區(qū)器茵汰。那么經(jīng)過這些之后枢里，是怎么到達(dá)broker的？ 主線程蹂午，消息累加器（RecordAccumulator）栏豺，se...

TJ_yyy

1概念： 消費(fèi)者負(fù)責(zé)訂閱主題，并且從主題上拉取消息豆胸，與其他消息中間件的不同是奥洼，kafka的消費(fèi)理念中還有一個(gè)消費(fèi)者組的概念，每個(gè)消費(fèi)者都對(duì)應(yīng)一個(gè)消費(fèi)者組晚胡，多個(gè)消費(fèi)者 組成一個(gè)...

TJ_yyy

producer 生產(chǎn)者 發(fā)送消息 consumer 消費(fèi)者 消費(fèi)消息（主動(dòng)拉攘榻薄） broker （消息服務(wù)） kafka 集群： 由多個(gè)broker 和 zookeeper...

TJ_yyy

原理 主從復(fù)制中有兩個(gè) thread 分別為 sql thread 和I/O Thread 主服務(wù)器 執(zhí)行的sql 語句都需要 在二進(jìn)制文件 binlog 中進(jìn)行記錄， I/...