返回游戏大厅

Kafka 高可用 (HA) 与高吞吐演示

可视化 Topic 分区、副本复制与 Consumer Group 消费机制

> Kafka Cluster Initialized. 3 Brokers, Topic 'orders' (3 Partitions, Replication Factor 2).

核心特性

  • 高吞吐 顺序 I/O 与 Zero-copy 实现百万级 TPS。
  • 高可用 分区副本机制 (Replication) 保证数据不丢失。
  • 可扩展 水平扩展 Broker 提升容量。

当前状态 (Status)

Brokers: 3
Partitions: 3
Consumers: 3
Messages Processed: 0
Consumer Lag: 0

原理说明

Partition (分区): Topic 被切分为多个分区，分布在不同 Broker 上以实现并行处理。

Replication (副本): 每个分区有 1 个 Leader 和多个 Follower。Leader 处理读写，Follower 被动同步。

Failover (故障转移): 当 Leader 所在 Broker 宕机，Controller 会从 ISR (In-Sync Replicas) 中选举新 Leader。

Consumer Group: 组内消费者分摊 Partition 进行消费，实现负载均衡。

Exactly-Once: 配合幂等性 Producer 与事务，可实现“精确一次”处理语义。

交互指南

  • 点击 发送消息 观察消息路由到不同分区的 Leader。
  • 点击 Kill Broker 模拟故障，观察 Partition Leader 的迁移 (变色)。
  • 开启 高吞吐模式 感受批量发送与快速消费。