[TOC]DelayedOperationPurgatory是一个相对独立的组件，它的主要功能是管理延迟操作。De...[作者空间]
[TOC]在上一节对副本机制的实现进行了分析，其中提到Broker能够处理来自KafkaController的Le...[作者空间]
[TOC]本文主要聊聊某一个broker上线与下线时，集群是如何感知的 zk事件 在KafkaController...[作者空间]
日志存储 基本概念 为了提高写入的性能，同一个分区中的消息是顺序写入的，这就避免了随机写入带来的性能问题。一个To...[作者空间]
[TOC]本篇接着讲述 Controller 的功能方面的内容，在 Kafka 中，一个 Topic 的新建、扩容...[作者空间]
[TOC] ReplicaManager 简介 关于 Produce 请求、Fetch 请求以及副本同步流程的启动...[作者空间]
前面两篇关于 Controller 的内容分别讲述了 Controller 选举和启动，以及副本状态机和分区状态机...[作者空间]
[TOC]本篇算是 Controller 部分的最后一篇，在前面讲述 ReplicaManager 时，留一个地方...[作者空间]
[TOC]本篇主要讲述 Controller 向各个 Broker 发送请求的模型，算是对 Controller ...[作者空间]
[TOC]在KafkaController初始化的过程中，多次遇见了LeaderAndIsr请求，这是broker...[作者空间]
[TOC]上篇讲述了 KafkaController 的启动流程，但是关于分区状态机和副本状态机的初始化并没有触及...[作者空间]
67)消费者源码-coondinator原理刨析 -63｝0:16 68)消费者源码-consumer初始化 ...[作者空间]
31 ）服务端代码设计-观察-kafka源码的包 31} 0：7 重点代码包： broker：D:\Git...[作者空间]
[TOC]Kafka 源码解析就正式进入了 Controller 部分，Controller 作为 Kafka S...[作者空间]
[TOC] 1. 准备工作 1.1 安装好jdk、scala sdk 1.2 安装好gradle gradle版本...[作者空间]
[TOC]本文主要讲述一个 topic 的创建过程，从 topic 是如何创建到 topic 真正创建成功的中间详...[作者空间]
[TOC] 日志的基本概念 在 Kafka 的官方文档中，最开始介绍 Kafka 的一句话是： Kafka is ...[作者空间]
[TOC] 集群成员关系 Kafka使用 Zookeeper来维护集群成员的信息。每个 broker都有一个唯一标...[作者空间]
1 、 broker管理之leo hw 含义 41} leo ： log and offset ...[作者空间]
