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