首页
宝藏大会员
OJ刷题
积分商城
海贼题库
潘多拉魔盒
Leetcode（在线刷面试算法）
牛客网（面试真题测评）
C/CPP 参考手册（在线文档+运行环境）
Git 操作在线学习
ProjectEuler（英文原站）
ProjectEuler（中英对照）
首页
宝藏大会员
OJ刷题
积分商城
海贼题库
潘多拉魔盒
Leetcode（在线刷面试算法）
牛客网（面试真题测评）
C/CPP 参考手册（在线文档+运行环境）
Git 操作在线学习
ProjectEuler（英文原站）
ProjectEuler（中英对照）
登录
注册
登录
注册
图解Kafka源码
第95任务： 图解kafka源码-消费者源码-consumer消费数据
查看课程
任务列表
第1-1任务： 源码阅读准备之基础知识准备
第1-2任务： 笔记
第2-1任务： 源码阅读准备之源码环境准备
第2-2任务： 图解Kafka源码–源码阅读准备之源码环境准备
第3-1任务： 源码阅读准备之源码剖析思路介绍
第3-2任务： 笔记
第4任务： 源码阅读准备之从一个demo入手
第5-1任务： 生产者源码之producer核心流程介绍
第5-2任务： producer核心流程.png
第6任务： 生产者源码之producer初始化(1)
第7任务： 生产者源码之producer元数据管理(1)
第8任务： 生产者源码之producer元数据管理(2)
第9任务： 生产者源码之producer源码核心流程初探(1)
第10任务： 生产者源码之producer源码核心流程初探(2)
第11任务： 生产者源码之producer加载元数据(1)
第12任务： 生产者源码之producer加载元数据(2)
第13任务： 生产者源码之producer加载元数据(3)
第14任务： 生产者源码之producer加载元数据(4)
第15任务： 生产者源码之分区选择
第16任务： recordaccumulator封装消息流程初探
第17任务： recordaccumulator封装消息流程初探2
第18任务： 生产者源码之copyonwritemap数据结构使用
第19-1任务： 生产者源码之把数据写到对应批次(分段加锁)
第19-2任务： 笔记
第20-1任务： 生产者之内存池设计
第20-2任务： 内存池.png
第21任务： 生产者源码之sender线程运行流程初探1
第22任务： 生产者源码之sender线程运行流程初探
第23任务： 生产者源码之一个batch什么条件下可以发送？
第24任务： 生产者源码之帅选可以发送消息的broker1
第25-1任务： 生产者源码之帅选可以发送消息的broker2
第25-2任务： 筛选可以发送消息的broker.png
第26任务： 生产者源码之kafka网络设计1
第27任务： 生产者源码之kafka网络设计2
第28-1任务： 生产者源码之kafka网络设计3
第28-2任务： Kafka的网络设计.png
第29任务： 生产者源码之如果网络没有建立好会发送消息吗？
第30任务： 生产者源码之producer终于要与broker建立1
第31任务： 生产者源码之producer终于要与broker建立2
第32-1任务： 生产者源码之producer终于要与broker建立3
第32-2任务： 终于与broker建立连接.png
第33任务： 生产者源码之生产者终于可以发送请求了1
第34任务： 生产者源码之生产者终于可以发送请求了2
第35任务： 生产者源码之生产者终于可以发送请求了3
第36任务： 生产者源码之生产者终于可以发送请求了4
第37-1任务： 生产者源码之生产者终于可以发送请求了5
第37-2任务： 终于发送网络请求了！.png
第38任务： 生产者源码之producer是如何处理粘包问题的(1)-1
第39任务： 生产者源码之producer是如何处理粘包问题的(1)-2
第40任务： 生产者源码之producer是如何处理拆包问题的
第41-1任务： 生产者源码之如何处理暂存状态的响应
第41-2任务： 响应消息的流转.png
第42任务： 生产者源码之如何处理响应消息
第43任务： 生产者源码之消息发送完了以后内存如何处理
第44任务： 生产者源码之消息有异常是如何处理的
第45任务： 生产者源码之如何处理超时的批次
第46任务： 生产者源码之如何处理长时间没有接受到响应的消息
第47-1任务： 生产者源码之生产者源码精华总结
第47-2任务： 笔记
第48任务： 服务端源码-网络-观察kafka源码的包(1)
第49任务： 服务端源码-网络-acceptor线程是如何启动的？
第50任务： 服务端源码-网络-processor线程是如何启动1
第51任务： 服务端源码-网络-processor线程是如何启动2
第52-1任务： 服务端源码-网络-processor线程是如何启动3
第52-2任务： Accept线程和Processor线程是如何配合工作？(1).png
第53任务： 服务端源码-网络-processor是如何接收请求的1
第54-1任务： 服务端源码-网络-processor是如何接收请求的2
第54-2任务： Accept线程和Processor线程是如何配合工作？(1).png
第55任务： processor线程是如何处理stagedreceives1
第56任务： processor线程是如何处理stagedreceives2
第57任务： 网络-requestqueue里的请求是如何被处理
第58任务： 服务端源码-网络-request是如何被处理的
第59任务： 服务端源码-网络-服务端给客户端发送响应做哪些准备工作1
第60-1任务： 服务端源码-网络-服务端给客户端发送响应做哪些准备工作2
第60-2任务： Accept线程和Processor线程是如何配合工作？.png
第61任务： 服务端源码-网络-响应消息是如何发送给客户端的1
第62任务： 服务端源码-网络-响应消息是如何发送给客户端的2
第63任务： 服务端源码-网络-支持超过并发的kafka网络设计
第64任务： 服务端源码-存储-核心对象关系梳理
第65任务： 服务端源码-存储-replicamanager写数据流程
第66任务： 服务端源码-存储-logmanager是什么？
第67任务： 服务端源码-存储-logmanager启动以后干什么？
第68任务： 服务端源码-存储-log的append总流程窥探
第69任务： 服务端源码-存储-新建logsegment策略(1)-1
第70-1任务： 服务端源码-存储-新建logsegment策略(1)-2
第70-2任务： ConcurrentSkipListMap原理.png
第71任务： 服务端源码-存储-如何使用内存映射写稀松索引(1)-1
第72-1任务： 服务端源码-存储-如何使用内存映射写稀松索引(1)-2
第72-2任务： 如何使用内存映射写稀松索引_笔记
第73-1任务： 服务端源码-存储-如何基于os cache写数据
第73-2任务： 笔记
第74任务： 服务端源码-存储-一条message的格式1
第75任务： 服务端源码-存储-一条message的格式2
第76任务： 服务端源码-存储-数据是如何flush的？
第77任务： 服务端源码-存储-发送响应给客户端
第78任务： 服务端源码-副本同步-replicafetcher线程启动
第79任务： 服务端源码-副本同步-follower发起fetch请求
第80任务： 服务端源码-副本同步-leader处理fetch请求
第81任务： leader和follower的leo，hw的更新流程1
第82-1任务： leader和follower的leo，hw的更新流程2
第82-2任务： Leader和Follower的LEO，HW更新流程.png
第83任务： 服务端源码-副本同步-isr定时检查线程
第84任务： 副本同步-如果follower fetch不到数据怎么办
第85-1任务： 集群管理-controller是如何选举出来的
第85-2任务： Kafka集群管理.png
第86任务： 服务端源码-集群管理-broker是如何注册的
第87任务： 服务端源码-集群管理-如何感知新注册进来的broker
第88任务： 服务端源码-集群管理-创建一个topic的流程
第89任务： 服务端源码-集群管理-元数据更新流程总结
第90-1任务： 消费者源码-coondinator原理剖析
第90-2任务： coondinator原理-Rebalance_笔记
第90-3任务： coondinator原理-Rebalance.png
第91任务： 消费者源码-consumer初始化
第92任务： 消费者源码-如何选举consumer leader
第93任务： 消费者源码-consumer leader如何制定分区方案
第94任务： 消费者源码-coondinator下发分区方案
第95任务： 图解kafka源码-消费者源码-consumer消费数据
第96任务： 消费者源码-自动提交偏移量
第97任务： 消费者源码-consumer发送心跳
