Kafkakafka Removed ✘✘✘ expired offsets in ✘✘✘ milliseconds.

Posted 2022-02-14 九师兄

文章目录

• 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。