繼續(xù)解答問(wèn)題:Kafka怎么樣才能不丟消息? 考慮一種比較極端的情況,整個(gè)Kafka集群用的是同一路電源,在掉電的情況下,消息是有可能丟失的,即便消息已經(jīng)被復(fù)制所有的ISR上...
繼續(xù)解答問(wèn)題:Kafka怎么樣才能不丟消息? 再次說(shuō)明下acks的語(yǔ)義如果acks=all,代表消息需要在所有ISR都被持久化成功后,Broker才可以告訴生產(chǎn)者,消息已經(jīng)發(fā)...
接下去幾篇關(guān)于可靠性的文章全部只討論一個(gè)經(jīng)典問(wèn)題:Kafka怎么樣才能不丟消息? 怎么樣的情況叫做丟消息?客戶(hù)端調(diào)用future = send(msg, callback),...
上一篇文章講的是在主線程,消息在調(diào)用了send后,消息內(nèi)容和該消息關(guān)聯(lián)的future對(duì)象被一起放入了RecordAccumulator中,future對(duì)象最終被send方法返...
Kafka為什么會(huì)有這么高吞吐? Kafka的發(fā)送邏輯和TCP的像極了,當(dāng)客戶(hù)端調(diào)用了producer.send(msg)后,Kafka的主線程并不會(huì)著急直接調(diào)用網(wǎng)絡(luò)底層將消...
由于 mac high sierra 系統(tǒng)有較大的變動(dòng),所以專(zhuān)門(mén)寫(xiě)一篇用mac high sierra 來(lái)編譯 openjdk8 的博客. 準(zhǔn)備階段 mac 系統(tǒng)版本 10...
親,RMQ可以實(shí)現(xiàn)分布式事務(wù)的,建議你先去體驗(yàn)下rocketmq-4.3.0中關(guān)于事務(wù)的例子,然后再來(lái)看一遍這篇文章,理解會(huì)好很多。
構(gòu)建基于RocketMQ的分布式事務(wù)服務(wù)說(shuō)在前面 Apache RocketMQ-4.3.0正式Release了事務(wù)消息的特性,順著最近的這個(gè)熱點(diǎn)。第一篇文章,就來(lái)聊一下在軟件工程學(xué)上的長(zhǎng)久的難題——分布式事務(wù)(D...
[TOC] 簡(jiǎn)介 kafka是一個(gè)分布式消息隊(duì)列。具有高性能、持久化、多副本備份、橫向擴(kuò)展能力。生產(chǎn)者往隊(duì)列里寫(xiě)消息,消費(fèi)者從隊(duì)列里取消息進(jìn)行業(yè)務(wù)邏輯。一般在架構(gòu)設(shè)計(jì)中起到解...
在查看Kafka的方法調(diào)用時(shí),斷點(diǎn)調(diào)試與日志打印會(huì)顯得非常重,如果學(xué)會(huì)了用Arthas這個(gè)武器,會(huì)讓你探索Kafka的源碼變得相對(duì)容易。 場(chǎng)景一 我知道接下來(lái),kafka一定...
@wj121 謝謝,相互學(xué)習(xí),如果覺(jué)得還不錯(cuò),請(qǐng)幫忙推廣下,我最近開(kāi)始寫(xiě)一些其它專(zhuān)題了
構(gòu)建基于RocketMQ的分布式事務(wù)服務(wù)說(shuō)在前面 Apache RocketMQ-4.3.0正式Release了事務(wù)消息的特性,順著最近的這個(gè)熱點(diǎn)。第一篇文章,就來(lái)聊一下在軟件工程學(xué)上的長(zhǎng)久的難題——分布式事務(wù)(D...
/Users/ericfei/Code/opensource/openjdk-jdk12u/src/hotspot/share/runtime/thread.cpp