kafka時間輪-輪詢方式

時間輪 kafka中存在大量的延時操作，比如延時生產，延時消費，延時刪除等。kafka並沒有使用JDK自帶的Timer和DelayQuene來實現延時的功能，而是基於時間輪的概念自定義實現了一個用於延時操作的定時器（SystemTimer）。 複雜度 jdk的Timer和DelayQuene的插入和刪除的複雜度爲O（nlogn） 根據源碼分析，Timer底層使用的TaskQueue，內部實現使用的

>>阅读原文<<