(5)Broker元数据(2)
2020-10-16 本文已影响0人
hedgehog1112
1. 什么是元数据缓存(MetadataCache)
Broker上的元数据缓存,Controller通过 UpdateMetadataRequest请求发送给Broker。每台 Broker 都保存这份相同数据,原因:
(1)Broker 能及时响应客户端发送元数据请求。不需所有请求都发Controller所在节点,均衡Controller节点负载
(2)副本管理器用它来获取 Broker 节点信息,事务管理器用它来获取分区 Leader 副本信息
2. MetadataCache源代码
MetadataCache实例化在Kafka Broker启动时完成,具体调用在 KafkaServer类的startup 方法中。
1.判断类:
2.获取类方法
3.更新类方法
https://blog.csdn.net/cl2010abc/article/details/108067223