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