Kafka 核心架构

核心组件

• Broker：Kafka服务节点

• Topic 主题：消息分类

• Partition 分区：分片，提升并发和吞吐量

• Replica 副本：高可用备份

• ISR：同步副本集合，保证数据可靠

• ConsumerGroup 消费者组：组内负载均衡，组间广播

Kafka 核心特点

• 基于磁盘顺序写，吞吐量极高

• 数据持久化、可回溯消费

• 分区机制支持超高并发

• 天然适合日志、大数据、流式处理

Kafka 安装与常用命令

包含：启动、创建主题、生产消息、消费消息、查看分区、查看偏移量

Kafka 可靠性机制

• acks 应答机制（0/1/all）

• 副本同步机制

• ISR 动态扩容收缩

• offset 偏移量持久化