29 | GroupMetadataManager：组元数据管理器是个什么东西？

Kafka中的GroupMetadataManager是一个关键的消费者组管理类，负责管理消费者组的元数据和位移信息。该类在消费者组Coordinator组件被创建时被实例化，每个Broker在启动过程中都会创建并维护一个GroupMetadataManager实例。它的功能包括添加消费者组、移除组、查询组等基础功能。GroupMetadataManager类的构造函数需要7个参数，其中包括brokerId、interBrokerProtocolVersion、config、replicaManager和zkClient等字段。除了构造函数所需的字段外，该类还定义了一些重要字段，如compressionType、groupMetadataCache、loadingPartitions、ownedPartitions和groupMetadataTopicPartitionCount等。在消费者组元数据管理方面，GroupMetadataManager类提供了查询获取组信息、添加组、移除组和加载组信息等方法。除了消费者组的管理，GroupMetadataManager类还提供消费者组位移的管理，包括位移数据的保存和查询。总的来说，GroupMetadataManager类是Kafka中非常重要的消费者组管理类，对于理解Kafka消费者组的工作原理和实现机制具有重要意义。另外，文章还介绍了storeOffsets方法的实现逻辑，该方法负责保存消费者组位移，通过过滤、判断Broker是否为Coordinator、构造位移主题消息、写入消息到位移主题以及更新消费者元数据等步骤完成位移信息的保存。文章还提到了getOffsets方法的实现逻辑，用于查询消费者组位移，通过读取groupMetadataCache中的组元数据，判断组状态并获取对应的位移数据。总的来说，GroupMetadataManager类在Kafka中扮演着至关重要的角色，对于理解消费者组管理和位移管理具有重要意义。