前言为什么我现在才写副本同步的解析呢，因为它太复杂了，仅仅是什么时候触发的副本同步，就涉及到KafkaController，LeaderAndIsr请求等，经过前面文章的梳理，现在时机正好 正文通常我 ...

前言本文主要讲解follower副本发起用于同步的fetch请求之前，获取了leader副本的leader epoch及其startOffset，关于leader epoch的介绍，可以看看前面的Le ...

在KafkaController初始化的过程中，多次遇见了LeaderAndIsr请求，这是broker之间通信的一个重要请求，它也是副本同步的关键步骤，本文主要分析KafkaApis对该请求的处理 ...

前言本文主要聊聊某一个broker上线与下线时，集群是如何感知的 zk事件在KafkaController#onControllerFailover方法中，会向zk注册一个brokerChangeHa ...

本文继续讲解Controller初始化过程，分析副本重分配过程 分区副本重分配首先什么是分区副本重分配(PartitionReassignment)，以下摘自《Apache Kafka实战》一书对其做 ...

本文承接上篇kafka-server端源码分析之Controller初始化，继续讲解Controller初始化过程中副本状态机与分区状态机的启动 副本状态机kafka将副本分为7个状态，下图是状态之间 ...

本文来分析下kafka的重要模块——Controller，主要介绍Controller的选举与初始化过程 KafkaController初始化的入口依然在KafkaServer#startup方法中1 ...

前言ConfigurationClassPostProcessor作为当前唯一的BeanFactoryPostProcessor，而且还是一个特殊的BeanDefinitionRegistryPost ...

这一篇比较简单，快速带大家过一下kafka如何连接ZooKeeper，以及kafka对节点事件监听的代码设计 ZooKeeper大致介绍kafka主要利用ZooKeeper选举Controller，这 ...

前言上文讲到了AnnotationConfigApplicationContext初始化的前两步，本文开始重点讲解第三步refresh。 类图AbstractApplicationContext是所有 ...