一、从 LeaderAndIsr 请求谈起 这个请求的作用是：通知集群中的节点，某个 Broker 成为某个分区的 Leader 或 Follower，以及 该分区最新的的副本状态信息。 1. 发送时 […]

延时请求（Delayed Operation），是指某些条件未满足，导致暂时无法处理的请求。例如，对于设置了 acks=all 的 Produce Request，Kafka 必须确保 ISR 中的所 […]

上一篇文章我们学习了三部分内容： controller 与 broker 的通信机制 controller 内部的事件处理机制 controller 的选举过程 这一节，我们以删除 topic 作为切 […]

Controller 是 Kafka 最核心的组件之一。一方面，它要为集群中的所有主题分区选举领导者副本；另一方面，它还承载着集群的全部元数据信息，并负责将这些元数据信息同步到其他 Broker 上 […]

文章开头依然放上 Kafka 的网络通信架构图。 第三节中阅读了 SocketServer 部分的源码，知道了请求时如何接收并返回的。这一节我们一起阅读一下 KafkaRequestHandler 的 […]

在研究学习 Kafka 的各个网络组件之前，我们先从整体上看一下完整的网络通信层架构： 由上图可以看出，Kafka 网络通信组件主要由两大部分构成：SocketServer 和 KafkaReques […]

上一节学习了一下 LogSegment 的相关知识，今天来看看 kafka 中 Log 对象的具体构造。不过在此之前，需要先了解一下面几个知识： 一、高水位 High Watermark 1. 高水位 […]

新年新气象，从今天起开始来看 Kafka 的源码。 首先简单描述一下 Kafka 的整体架构： 发布消息的客户端程序称为生产者（Producer），Producer 通常持续不断地向一个或多个 Top […]