前言为了方便大家阅读，单独用一篇文章罗列出各个技术源码的阅读目录，目前主要分为以下几个方向: Kafka、JDK、Spring、Spring Boot、Spring Cloud 版本信息项目源码因版本 ...

背景Consumer需要和Coordinator保持心跳，来证明当前消费者线程存活，有消费消息的能力，但心跳又不止这么简单，它也是Coordinator下发rebalance请求的通道，同时Consu ...

前言本文主要聊聊kafka生产者端的缓冲池设计，不了解ByteBuffer的同学需要先看看我之前的文章ByteBuffer浅显易懂的图解原理 生产者缓冲池的应用kafka采用延迟批量发送的方式来提高了 ...

本文主要聊聊java线程池ThreadPoolExecutor的源码实现，以及如何通过Apollo配置中心来达到动态调整线程池大小 任务执行过程简述首先我还是用图文来说明一下线程池执行任务的大致原 ...

前言本文聊聊消费者拉取消息时向kafka server发送LIST_OFFSETS的请求，这个请求的功能一言以蔽之:根据请求参数中的timeStamp获取消费者(或副本)能够fetch的位移 它的使用 ...

前言本文聊聊消费者如何获取上次提交的位移 OffsetFetch请求在Kafka消费者-源码分析(上)一文的最后，Consumer在refreshCommittedOffsetsIfNeeded方法发 ...

前言衔接上文kafka-rebalance之JoinGroup, 我们已经知道在JoinGroup请求的响应中，leader consumer会计算分区分配方案，并发起SyncGroup请求，本文讲解 ...

前言在AbstractCoordinator的initiateJoinGroup方法中，通过判断joinFuture为null，发起了JoinGroupRequest请求，本文主要讲解GroupCoo ...

本文主要介绍Consumer在第一次拉取消息前，获取Coordinator的过程，衔接Kafka消费者-源码分析一文 前言在ConsumerCoordinator的poll方法中，我们聊到第一次p ...

本文从消费者拉取消息开始分析消费流程，但kafka并不是单纯的在poll方法中拉取消息，鉴于消费者组的存在，以及Rebalance动作，使整个消费流程的复杂度直线上升，因此需要比生产者花费更多的章节 ...