(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

上一篇下一篇

猜你喜欢

热点阅读