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