〇、【引子】 由于老婆经常拿着手机问我，“这件衣服好看吗” “这件衣服我能穿吗”...... 我实在是受不了了，所以萌生出了写一个 AI 换衣工具的想法。 虽然豆包已经有这个功能了，但是操作起来比较麻 […]
延时请求（Delayed Operation），是指某些条件未满足，导致暂时无法处理的请求。例如，对于设置了 acks=all 的 Produce Request，Kafka 必须确保 ISR 中的所 […]
一、从 LeaderAndIsr 请求谈起 这个请求的作用是：通知集群中的节点，某个 Broker 成为某个分区的 Leader 或 Follower，以及 该分区最新的的副本状态信息。 1. 发送时 […]
上一篇文章我们学习了三部分内容： controller 与 broker 的通信机制 controller 内部的事件处理机制 controller 的选举过程 这一节，我们以删除 topic 作为切 […]
Controller 是 Kafka 最核心的组件之一。一方面，它要为集群中的所有主题分区选举领导者副本；另一方面，它还承载着集群的全部元数据信息，并负责将这些元数据信息同步到其他 Broker 上 […]
文章开头依然放上 Kafka 的网络通信架构图。 第三节中阅读了 SocketServer 部分的源码，知道了请求时如何接收并返回的。这一节我们一起阅读一下 KafkaRequestHandler 的 […]
在研究学习 Kafka 的各个网络组件之前，我们先从整体上看一下完整的网络通信层架构： 由上图可以看出，Kafka 网络通信组件主要由两大部分构成：SocketServer 和 KafkaReques […]
上一节学习了一下 LogSegment 的相关知识，今天来看看 kafka 中 Log 对象的具体构造。不过在此之前，需要先了解一下面几个知识： 一、高水位 High Watermark 1. 高水位 […]