Apache Kafka 源碼剖析
Getting Start 下載 http://kafka.apache.org/ 優點和應用場景 Kafka消息驅動，符合發布-訂閱模式，優點和應用范圍都共通 發布-訂閱模式優點 解耦合 ： 兩個應用不需要相互調用 可擴展性 ： 消費者的個數 ...
原文：Apache Kafka源碼分析 - KafkaApis
kafka apis反映出kafka broker server可以提供哪些服務，broker server主要和producer，consumer，controller有交互，搞清這些api就清楚了broker server的所有行為 handleOffsetRequest 提供對offset的查詢的需求，比如查詢earliest，latest offset是什么，或before某個時間戳的of ...
2015-10-27 11:30 0 2591 推薦指數：
相關推薦
Kafka源碼分析(二) - 生產者
的消息 step 4：發送消息 二. 線程模型 三. 源碼分析 1 ...
Kafka源碼解析（二）---Log分析
上一篇文章講了LogSegment和Log的初始化，這篇來講講Log的主要操作有哪些。 一般來說Log 的常見操作分為 4 大部分。 高水位管理操作 日志段管理 關鍵位移值管理 ...
Kafka 0.8源碼分析—ZookeeperConsumerConnector
1.HighLevelApi High Level Api是多線程的應用程序，以Topic的Partition數量為中心。消費的規則如下： 一個partition只能被同一個Consumer ...
Apache Curator之InterProcessMutex源碼分析（四）
上篇文章通過秒購的例子對InterProcessMutex鎖有了初步認識，本文將通過對源碼進行分析帶你進入分布式鎖的世界。 老規矩先上圖，為了更清晰的了解獲取鎖，釋放鎖的過程，下圖簡化了一些細節，使整個流程更加通暢。 下面將逐個方法去分析 ...
kafka源碼分析之一server啟動分析
0. 關鍵概念 關鍵概念 Concepts Function Topic 用於划分Message的邏輯概念，一個Topic可以分布在多個Broker上。 Partition 是Kafka中橫向 ...
spark-streaming-kafka-0-10源碼分析
轉發請注明原創地址http://www.cnblogs.com/dongxiao-yang/p/7767621.html 本文所研究的spark-streaming代碼版本為2.3.0-SNAPSHOT spark-streaming為了匹配0.10以后版本的kafka客戶端變化推出 ...
源碼分析Kafka 消息拉取流程
本節重點討論 Kafka 的消息拉起流程。 @ 目錄 １、KafkaConsumer poll 詳解 1.1 KafkaConsumer updateAssignmentMetadataIfNeeded 詳解 1.1.1 ...