Kafka核心源码解读学习心得

Kafka核心源码解读学习心得

AbstractFetcherThread：拉取消息分几步？    

ControllerChannelManager：Controller如何管理请求发送？    

ControllerEventManager：变身单线程后的Controller如何处理事件？    

Controller选举是怎么实现的？    

Controller元数据：Controller都保存有哪些东西？有几种状    

Controller元数据：Controller都保存有哪些东西？有几种状态？    

GroupCoordinator：在Rebalance中，Coordinator如何处理成员入组？    

GroupCoordinator：在Rebalance中，如何进行组同步？    

GroupMetadataManager：查询位移时，不用读取位移主题？    

GroupMetadataManager：位移主题保存的只是位移吗？    

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

MetadataCache：Broker是怎么异步更新元数据缓存的？    

ReplicaFetcherThread：Follower拉取Leader消息是如何实现的？    

ReplicaManager（上）：必须要掌握的副本管理类定义和核心字段    

ReplicaManager（下）：副本管理器是如何管理副本的    

ReplicaManager（下）：副本管理器是如何管理副本的？    

ReplicaManager（中）：副本管理器是如何读写副本的？    

日志（上）：日志究竟是如何加载日志段的？    

日志（下）：彻底搞懂Log对象的常见操作    

日志段：保存消息文件的对象是怎么实现的？    

如何理解Controller在Kafka集群中的作用？    

索引（上）：改进的二分查找算法在Kafka索引的应用    

索引（下）：位移索引和时间戳索引的区别是什么？    

消费者组元数据（上）：消费者组都有哪些元数据？    

消费者组元数据（下）：Kafka如何管理这些元数据？