【原創】kafka consumer源代碼分析
顧名思義，就是kafka的consumer api包。 一、ConsumerConfig.scala Kafka consumer的配置類，除了一些默認值常量及驗證參數的方法之外，就是consumer的配置參數了，比如group.id, consumer.id等，詳細列表見官網 ...
原文：【原創】Kakfa message包源代碼分析
筆者最近在研究Kafka的message包代碼，有了一些心得，特此記錄一下。其實研究的目的從來都不是只是看源代碼，更多地是想借這個機會思考幾個問題：為什么是這么實現的 你自己實現方式是什么 比起人家的實現方式，你的方案有哪些優缺點 任何消息引擎系統最重要的都是定義消息，使用什么數據結構來保存消息和消息隊列 剛剛思考這個問題的時候，我自己嘗試實現了一下Message的定義： 可以看出，實現的方式是 ...
2015-03-29 17:08 0 1957 推薦指數：
相關推薦
【原創】Kafka console consumer源代碼分析(一)
上一篇中分析了Scala版的console producer代碼，這篇文章為讀者帶來一篇console consumer工作原理分析的隨筆。其實不論是哪個consumer，大部分的工作原理都是類似的。本文利用console consumer作為切入點，既容易理解又不失一般性 ...
hadoop源代碼分析（4）-org.apache.hadoop.util包-GenericOptionsParser類【原創】
一 准備 hadoop版本：1.0.3，GenericOptionsParser所在的包：org.apache.hadoop.util 學習方法：理解GenericOptionsParser這個解析器的使用地方，從構造函數入手，理解GenericOptionsParser整個類 ...
mybatis源代碼分析之binding包
在使用ibatis執行數據庫訪問時，會調用形如 這樣的代碼。這樣的形式要求調用方選擇需要使用的函數（queryForObject、queryForList、update），還需要告訴這個函數具體執行哪一個statement（上文中是“getCityByCityId”），在這個過程中 ...
Mybatis源代碼分析之metadata包
數據庫中我們最常用到的元素就是database、table、column。Mybatis作為強大的ORM框架，當中也包含了獲取處理這些元素的代碼，本篇將介紹相關的內容。 一、Catalog & Schema 在介紹具體的代碼實現之前，我們需要先了解兩個 ...
Mybatis源代碼分析之parsing包
parsing，從字面上理解就是編譯解析的意思，那么這個包中的內容就應該和mybatis配置文件的編譯解析有關系。本文首先會按照引用層次來分別介紹這個包中各個類的作用，而后再用實際的例子解釋它們是如何組合到一起去解決了什么樣的問題。 一、類和接口介紹 1.TokenHandler ...
【原創】k8s源代碼分析-----kubelet（1）主要流程
本人空間鏈接http://user.qzone.qq.com/29185807/blog/1460015727 源代碼為k8s v1.1.1穩定版本號 kubelet代碼比較復雜 ...
mybatis $和#源代碼分析
JDBC中，主要使用兩種語句，一種是支持參數化和預編譯的PreparedStatement,支持原生sql,支持設置占位符，參數化輸入的參數，防止sql注入攻擊，在mybatis的mapper配置文件 ...