一、服务端接收消费者拉取数据的方法二、遍历请求中需要拉取数据的主题分区集合，分别执行查询数据操作，1、会选择合适的副本读取本地日志数据(2.4版本后支持主题分区多副本下的读写分离)三、会判断当前请求是主题分区Follower发送的拉取数据请求还是消费者客户端拉取数据请求1、拉取数据之前首先要得到leaderIsrUpdateLock的读锁2、readFromLocalLog读取本地日志数据四、读取日志数据就是读取的segment文件1、获取当前本地日志的基础数据(高水位线，偏移量等)，2、遍历segment，直到从segment读取到数据五、创建带有读取指定文件位置通道的文件记录对象FileR

文章目录前言一、OffsetExplorer是什么？二、安装包下载，进行安装1.工具的使用-新建链接2.添加链接名和版本号2.切换至“Advanced”teb页添加访问kafka信息3.kafka相关信息查看3.kafka相关信息查看总结前言当要读取kafka中的数据时，在服务器上查看比较麻烦，数据量较大，也不是很直观。此时就需要一款简洁，使用方便的可视化工具了，嘻嘻，OffsetExplorer（以前叫：kafka-Tool）就是一个不错的选择。一、OffsetExplorer是什么？OffsetExplorer（以前叫：kafka-Tool）：学名叫：偏移资源管理器，是一款kafka的可视

前言：为什么选择Kafka？Kafka相对于其它消息系统的优点支持集群模型，扩展性好。scalability将Topic分区到所有实例上，容错性好。resilientKafka的特点使用topic发布/订阅消息。Topic支持副本，分布在不同机器上。集群的节点可以是多个topic的分区的Leader节点，而不是整个topic的leader节点。image.png1环境配置1.1添加Kafka依赖注意：Kafka暂时没有Starter。org.springframework.kafkaspring-kafka1.2SpringBoot对Kakfa的自动操作添加spring-kafka会触发Spr