摘要:本節重點討論 Kafka 的消息拉起流程。 @ "TOC" 1、KafkaConsumer poll 詳解 消息拉起主要入口為:KafkaConsumer poll方法,其聲明如下: ~~~java public ConsumerRecords poll(final Duration timeout 閱讀全文
posted @ 2020-01-15 20:34 中間件興趣圈 閱讀 (173) 評論 (0) 編輯
摘要:溫馨提示:整個 Kafka 專欄基于 kafka 2.2.1 版本。 1、KafkaConsumer 概述 根據 KafkaConsumer 類上的注釋上來看 KafkaConsumer 具有如下特征: 在 Kafka 中 KafkaConsumer 是線程不安全的。 2.2.1 版本的KafkaC 閱讀全文
posted @ 2020-01-12 23:07 中間件興趣圈 閱讀 (141) 評論 (0) 編輯
摘要:溫馨提示:本文基于 Kafka 2.2.1 版本。 上文 "《源碼分析 Kafka 消息發送流程》" 已經詳細介紹了 KafkaProducer send 方法的流程,該方法只是將消息追加到 KafKaProducer 的緩存中,并未真正的向 broker 發送消息,本文將來探討 Kafka 的 S 閱讀全文
posted @ 2020-01-08 19:21 中間件興趣圈 閱讀 (117) 評論 (0) 編輯
摘要:溫馨提示:本文基于 Kafka 2.2.1 版本。本文主要是以源碼的手段一步一步探究消息發送流程,如果對源碼不感興趣,可以直接跳到文末查看消息發送流程圖與消息發送本地緩存存儲結構。 從上文 "初識 Kafka Producer 生產者" ,可以通過 KafkaProducer 的 send 方法發送 閱讀全文
posted @ 2020-01-05 17:36 中間件興趣圈 閱讀 (150) 評論 (0) 編輯
摘要:溫馨提示:整個 Kafka Client 專欄基于 kafka 2.3.0 版本。 @ "TOC" 1、KafkaProducer 概述 根據 KafkaProducer 類上的注釋上來看 KafkaProducer 具有如下特征: KafkaProducer 是線程安全的,可以被多個線程交叉使用。 閱讀全文
posted @ 2019-12-31 21:04 中間件興趣圈 閱讀 (145) 評論 (0) 編輯
摘要:1、背景 公司一個 RocketMQ 集群由4主4從組成,突然其中3臺服務器“竟然”在同一時間下線,其監控顯示如下: 依次查看三臺機器的監控圖形,時間戳幾乎完美“吻合”,不可思議吧。 2、故障分析 出現問題,先二話不說,馬上重啟各服務器,盡快恢復集群,降低對業務的影響,接下來開始對日志進行分析。 J 閱讀全文
posted @ 2019-12-29 15:51 中間件興趣圈 閱讀 (151) 評論 (1) 編輯
摘要:本文將在 "RocketMQ 消息發送system busy、broker busy原因分析與解決方案" 的基礎上,結合生產上的日志嘗試再次理解 broker busy 以及探討解決方案。 首先,broker busy 相關的日志關鍵字如下: [REJECTREQUEST]system busy t 閱讀全文
posted @ 2019-12-26 22:05 中間件興趣圈 閱讀 (23) 評論 (0) 編輯
摘要:本文主要介紹如何將 RocketMQ 集群從原先的主從同步升級到主從切換。 首先先介紹與 DLedger 多副本即 RocketMQ 主從切換相關的核心配置屬性,然后嘗試搭建一個主從同步集群,再從原先的 RocketMQ 集群平滑升級到 DLedger 集群的示例,并簡單測試一下主從切換功能。 @ 閱讀全文
posted @ 2019-12-22 17:26 中間件興趣圈 閱讀 (128) 評論 (0) 編輯
摘要:源碼分析 RocketMQ DLedger 多副本系列已經進行到第 8 篇了,前面的章節主要是介紹了基于 raft 協議的選主與日志復制,從本篇開始將開始關注如何將 DLedger 應用到 RocketMQ中。 摘要:詳細分析了RocketMQ DLedger 多副本(主從切換) 是如何整合到 Ro 閱讀全文
posted @ 2019-12-19 23:10 中間件興趣圈 閱讀 (164) 評論 (0) 編輯
摘要:上一篇 "源碼分析 RocketMQ DLedger(多副本) 之日志復制(傳播)" ,可能有不少讀者朋友們覺得源碼閱讀較為枯燥,看的有點云里霧里,本篇將首先梳理一下 RocketMQ DLedger 多副本關于日志復制的三個核心流程圖,然后再思考一下在異常情況下如何保證數據一致性。 @ "TOC" 閱讀全文
posted @ 2019-12-17 21:19 中間件興趣圈 閱讀 (111) 評論 (0) 編輯
四川金7乐历史开奖号码查询