Kafka主题增删改原理探析：深入理解操作背后的机制 置顶！ 1、主题创建 1.1、方式 用kafka自带的脚本创建一个主题，主题名：topic_a，分区数为3，副本因子为3，命令如下： 方式一 指定3分区3副本，由kafk · kafka MQ
Kafka消息消费原理探究：架构、流程与核心组件解析 1、消费组状态 消费组有5个状态（GroupState）： Empty：当前无成员 PreparingRebalance：准备重平衡 AwaitingSync： · kafka MQ
Kafka原理与源码解析：LeaderAndIsr 请求 1、简介 当一个主题分区的 Leader、ISR发生改变时，Controller会向 Broker 发送 LeaderAndIsr 请求。这个请求中会封装分区的元 · kafka MQ
Kafka控制器源码解读：深入探索核心架构与实现细节 置顶！ 1、简述 控制器（controller）是Kafka集群中的一个核心组件，负责管理和协调集群的状态。 任何一个 broker 都可以作为 controller，但 · kafka MQ
Kafka副本管理器 Broker 启动 Broker在启动时，会启动一个副本管理器，代码如下： def startup() { ... // 1、ReplicaManager创建 r · kafka MQ
Kafka消息存储设计探索：高效稳定的数据存储之道 1、基本概念 主题 Topic，kafka中的消息以主题为基本单位来归类，各个主题逻辑上相互独立。 分区 Partition，每个主题又可以分为一个或多个分区，每 · kafka MQ
Kafka原理与源码解析：处理Produce请求 生产者发送消息，kafka server 端在收到 Produce请求后，会由 KafkaApis 进行处理。 KafkaApis 是 server 端处理所有请 · kafka MQ
Kafka消息发送原理揭秘：深入理解消息传输机制 置顶！ 1、创建主题 先用kafka脚本创建一个主题：topic_a，分区数：3，副本数：1 bin/kafka-topics.sh --create --topic t · kafka MQ
