Kafka的消息消费是以消费的group为单位;
同属一个group中的多个consumer分别消费topic的不同partition;
同组内consumer的变化, partition变化, coordinator...的变化都会引发balance;
消费的offset的提交
Kafka wiki: Kafka Detailed Consumer Coordinator Design 和 Kafka Client-side.../main/scala/kafka/coordinator/GroupMetadataManager.scala
作用: 是比较核心的一个类, 负责所有group的管理, offset消息的读写和清理等...存到了__consumer_offsets里, , 它的key是 groupId
offset和group信息的写入: 实际上是普通的消息写入没有本质上的区别, 可参考Kafka是如何处理客户端发送的数据的...topic消息的加载
__consumer_offsets作为一个topic, 也是有多个partiton的, 每个partiton也是有多个复本的, partition也会经历leader的选举