這個客戶端透明的處理kafka broker的失敗，並透明的適應它在集群內提取的主題分割槽
這個客戶端使用「consumer group」與broker進行互動來負載均衡
這個消費者為了獲取資料和必須的broker維持了tcp連線
消費者使用後未能關閉會導致連線洩露
這個消費者是執行緒不安全的
這個客戶端可以和0.10.0及以上版本進行通訊，新的或者舊的版本可能不支援某些功能。例如：0.10.0的broker不支援offsetfortimes,因為這個功能是在0.10.1中新增的，如果你呼叫的api在執行的broker的版本不支援的話，會丟擲unsupportedversionexception
kafka為分割槽中的每一條記錄維護乙個數值偏移，此偏移量充當該分區內記錄的唯一識別符號，並且還表示消費者在分割槽中的位置
AbstractCollection原始碼分析
abstractcollection抽象類提供了collection的骨架實現,collection分析請看 這裡直接看它的 是如何實現的.public abstract iterator iterator 該方法沒有實現.public abstract int size 該方法沒有實現.publi...
ThreadPoolExecutor原始碼閱讀
執行緒池解決兩個問題 一是復用執行緒，減少建立銷毀執行緒帶來系統開銷 二是限定系統資源使用邊界，避免大量執行緒消耗盡系統記憶體 適用於互不依賴，執行時間短，不需要對執行緒控制操作的執行緒 新增任務時，1.若執行緒數量小於corepoolsize，則新增執行緒執行任務 2.若執行緒數量大於等於core...
OrangePi One Android 原始碼編譯
一 系統環境搭建參照 二 lichee原始碼編譯 1.檢視help build.sh h2.配置核心 cd linux 3.4 make arch arm menuconfig 進入配置頁面，上下移動列表，空格是選擇列表，左右移動選擇退出選項 3.首次編譯執行清除 在 lichee linux3.4...