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