弱水三千 只取一瓢
發(fā)簡(jiǎn)信
IP屬地：浙江
-
-
Kafka源碼分析（八）消息發(fā)送可靠性——flush.messages
繼續(xù)解答問(wèn)題：Kafka怎么樣才能不丟消息？ 考慮一種比較極端的情況，整個(gè)Kafka集群用的是同一路電源，在掉電的情況下，消息是有可能丟失的，即便消息已經(jīng)被復(fù)制所有的ISR上...
-
Kafka源碼分析（七）消息發(fā)送可靠性——min.insync.replicas
繼續(xù)解答問(wèn)題：Kafka怎么樣才能不丟消息？ 再次說(shuō)明下acks的語(yǔ)義如果acks=all，代表消息需要在所有ISR都被持久化成功后，Broker才可以告訴生產(chǎn)者，消息已經(jīng)發(fā)...
-
Kafka源碼分析（六）消息發(fā)送可靠性——acks
接下去幾篇關(guān)于可靠性的文章全部只討論一個(gè)經(jīng)典問(wèn)題：Kafka怎么樣才能不丟消息？ 怎么樣的情況叫做丟消息？客戶(hù)端調(diào)用future = send(msg, callback)，...
-
Kafka源碼分析（四）高吞吐核心——RecordAccumulator消息發(fā)送過(guò)程
上一篇文章講的是在主線程，消息在調(diào)用了send后，消息內(nèi)容和該消息關(guān)聯(lián)的future對(duì)象被一起放入了RecordAccumulator中，future對(duì)象最終被send方法返...
-
Kafka源碼分析（三）高吞吐核心——RecordAccumulator消息累積過(guò)程Kafka為什么會(huì)有這么高吞吐？ Kafka的發(fā)送邏輯和TCP的像極了，當(dāng)客戶(hù)端調(diào)用了producer.send(msg)后，Kafka的主線程并不會(huì)著急直接調(diào)用網(wǎng)絡(luò)底層將消...
-
歡迎關(guān)注我的公眾號(hào)：程序員追風(fēng)
-
如果讀完覺(jué)得有收獲的話(huà)，歡迎關(guān)注我的公眾號(hào)：占小狼的博客 <a href="https://links.jianshu.com/go?to=https%3A%2F%2Fdwz.cn%2FD8Q1K7Ft" target="_blank">https://dwz.cn/D8Q1K7Ft</a><br><br><br>
-
mac 10.13.x編譯openjdk8
由于 mac high sierra 系統(tǒng)有較大的變動(dòng),所以專(zhuān)門(mén)寫(xiě)一篇用mac high sierra 來(lái)編譯 openjdk8 的博客. 準(zhǔn)備階段 mac 系統(tǒng)版本 10...
-
-
Java 程序員<br><br>個(gè)人網(wǎng)站：<a href="https://links.jianshu.com/go?to=https%3A%2F%2Fthinkinjava.cn" target="_blank">https://thinkinjava.cn</a><br>Stay hungry. Stay foolish.
-
親，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...
-
震驚了！原來(lái)這才是kafka！[TOC] 簡(jiǎn)介 kafka是一個(gè)分布式消息隊(duì)列。具有高性能、持久化、多副本備份、橫向擴(kuò)展能力。生產(chǎn)者往隊(duì)列里寫(xiě)消息，消費(fèi)者從隊(duì)列里取消息進(jìn)行業(yè)務(wù)邏輯。一般在架構(gòu)設(shè)計(jì)中起到解...
-
Kafka源碼分析（二）Arthas調(diào)試Kafka
在查看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...
-
-
OpenJDK源碼分析（二）—— OpenJDK Clion斷點(diǎn)調(diào)試環(huán)境/Users/ericfei/Code/opensource/openjdk-jdk12u/src/hotspot/share/runtime/thread.cpp
