發(fā)簡信
IP屬地：浙江
-
Kafka源碼分析（八）消息發(fā)送可靠性——flush.messages
繼續(xù)解答問題：Kafka怎么樣才能不丟消息？ 考慮一種比較極端的情況，整個(gè)Kafka集群用的是同一路電源，在掉電的情況下，消息是有可能丟失的，即...
-
Kafka源碼分析（七）消息發(fā)送可靠性——min.insync.replicas
繼續(xù)解答問題：Kafka怎么樣才能不丟消息？ 再次說明下acks的語義如果acks=all，代表消息需要在所有ISR都被持久化成功后，Broke...
-
Kafka源碼分析（六）消息發(fā)送可靠性——acks
接下去幾篇關(guān)于可靠性的文章全部只討論一個(gè)經(jīng)典問題：Kafka怎么樣才能不丟消息？ 怎么樣的情況叫做丟消息？客戶端調(diào)用future = send(...
-
Kafka源碼分析（四）高吞吐核心——RecordAccumulator消息發(fā)送過程
上一篇文章講的是在主線程，消息在調(diào)用了send后，消息內(nèi)容和該消息關(guān)聯(lián)的future對(duì)象被一起放入了RecordAccumulator中，fut...
-
Kafka源碼分析（三）高吞吐核心——RecordAccumulator消息累積過程Kafka為什么會(huì)有這么高吞吐？ Kafka的發(fā)送邏輯和TCP的像極了，當(dāng)客戶端調(diào)用了producer.send(msg)后，Kafka的主線程...
-
Kafka源碼分析（二）Arthas調(diào)試Kafka
在查看Kafka的方法調(diào)用時(shí)，斷點(diǎn)調(diào)試與日志打印會(huì)顯得非常重，如果學(xué)會(huì)了用Arthas這個(gè)武器，會(huì)讓你探索Kafka的源碼變得相對(duì)容易。 場景一...
-
-
OpenJDK源碼分析（二）—— OpenJDK Clion斷點(diǎn)調(diào)試環(huán)境/Users/ericfei/Code/opensource/openjdk-jdk12u/src/hotspot/share/runtime/...
-
OpenJDK源碼分析（一）—— Mac OpenJDK 編譯
Mac OSX版本 10.14.6 (18G103) xcode版本 Version 11.1 (11A1027) 編譯依賴 LLVM編譯器 B...