文章目錄
- 1.概述
- 2. 原始碼解讀
-
- 2.1 cleanupGroupMetadata
-
- 2.1.1 cleanupGroupMetadata
- 2.1.2 removeExpiredOffsets
- M.參考
1.概述
kafka 消費組(consumer group),
消費組指的是多個消費者(consumer)組成起來的一個組,它們共同消費 topic 的所有訊息,并且一個 topic 的一個 partition 只能被一個 consumer 消費,
Kafka 為消費者組定義了 5 種狀態,它們分別是:Empty、Dead、PreparingRebalance、CompletingRebalance 和 Stable,
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/423264.html
標籤:其他
上一篇:Rocketmq原始碼決議-Producer訊息發送程序(1)
下一篇:RocketMQ訊息保障
