【Kafka】kafka Removed ✘✘✘ expired offsets in ✘✘✘ milliseconds.

【Kafka】kafka Removed ✘✘✘ expired offsets in ✘✘✘ milliseconds.

文章目录

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。