Kafka核心源码解读

10100-01-10 01__日志段:保存消息文件的对象是怎么实现的?
10100-01-10 02__日志(上):日志究竟是如何加载日志段的?
10100-01-10 03__日志(下):彻底搞懂Log对象的常见操作
10100-01-10 04__索引(上):改进的二分查找算法在Kafka索引的应用
10100-01-10 05__索引(下):位移索引和时间戳索引的区别是什么?
10100-01-10 06__请求通道:如何实现Kafka请求队列?
10100-01-10 07__SocketServer(上):Kafka到底是怎么应用NIO实现网络通信的?
10100-01-10 08__SocketServer(中):请求还要区分优先级?
10100-01-10 09__SocketServer(下):请求处理全流程源码分析
10100-01-10 10__KafkaApis:Kafka最重要的源码入口,没有之一
10100-01-10 11__Controller元数据:Controller都保存有哪些东西?有几种状态?
10100-01-10 12__ControllerChannelManager:Controller如何管理请求发送?
10100-01-10 126-Kafka核心源码解读
10100-01-10 13__ControllerEventManager:变身单线程后的Controller如何处理事件?
10100-01-10 14__Controller选举是怎么实现的?
10100-01-10 15__如何理解Controller在Kafka集群中的作用?
10100-01-10 16__TopicDeletionManager:_Topic是怎么被删除的?
10100-01-10 17__ReplicaStateMachine:揭秘副本状态机实现原理
10100-01-10 18__PartitionStateMachine:揭秘分区状态机实现原理
10100-01-10 19__TimingWheel:探究Kafka定时器背后的高效时间轮算法
10100-01-10 20__DelayedOperation:Broker是怎么延时处理请求的?
10100-01-10 21__AbstractFetcherThread:拉取消息分几步?
10100-01-10 22__ReplicaFetcherThread:Follower拉取Leader消息是如何实现的?
10100-01-10 23__ReplicaManager(上):必须要掌握的副本管理类定义和核心字段
10100-01-10 24__ReplicaManager(中):副本管理器是如何读写副本的?
10100-01-10 25__ReplicaManager(下):副本管理器是如何管理副本的?
10100-01-10 26__MetadataCache:Broker是怎么异步更新元数据缓存的?
10100-01-10 27__消费者组元数据(上):消费者组都有哪些元数据?
10100-01-10 28__消费者组元数据(下):Kafka如何管理这些元数据?
10100-01-10 29__GroupMetadataManager:组元数据管理器是个什么东西?
10100-01-10 30__GroupMetadataManager:位移主题保存的只是位移吗?
10100-01-10 31__GroupMetadataManager:查询位移时,不用读取位移主题?
10100-01-10 32__GroupCoordinator:在Rebalance中,Coordinator如何处理成员入组?
10100-01-10 33__GroupCoordinator:在Rebalance中,如何进行组同步?
10100-01-10 导读__构建Kafka工程和源码阅读环境、Scala语言热身
10100-01-10 结束语__源码学习,我们才刚上路呢
10100-01-10 开篇词__阅读源码,逐渐成了职业进阶道路上的“必选项”
10100-01-10 期末测试__一套习题,测试你的掌握程度
10100-01-10 期中测试__这些源码知识,你都掌握了吗?
10100-01-10 特别放送(二)_一篇文章带你了解参与开源社区的全部流程
10100-01-10 特别放送(三):我是怎么度过日常一天的?
10100-01-10 特别放送(四)_20道经典的Kafka面试题详解
10100-01-10 特别放送(五)__Kafka_社区的重磅功能:移除_ZooKeeper_依赖
10100-01-10 特别放送(一)_经典的Kafka学习资料有哪些?
10100-01-10 重磅加餐__带你快速入门Scala语言