Docker中部署高可用Kafka集群需：多Broker+ZooKeeper/KRaft+网络隔离+副本机制；推荐ZooKeeper三节点，Broker设唯一ID和advertised.listeners；Topic副本数≥3、min.isr=2、禁用unclean选举；验证ISR与故障转移。
在 Docker 中部署 Kafka 集群并实现高可用，核心是：用多个独立 Kafka Broker 实例 + 外部 ZooKeeper（或 KRaft 模式）+ 正确的网络与配置隔离 + 副本机制保障容错。ZooKeeper 模式更成熟，KRaft（Kafka Raft Metadata mode）是新方向但生产环境建议谨慎评估。
准备多节点 Kafka Broker 容器
每个 Broker 必须有唯一 broker.id、绑定正确的 advertised.listeners（对外暴露地址）、且能互相发现。推荐用 Docker Compose 管理多容器协同：
- 定义 3 个 Kafka 服务（kafka1/kafka2/kafka3），分别设置
broker.id=1/2/3 -
advertised.listeners设为宿主机可访问的地址，如PLAINTEXT://localhost:9092（开发）或PLAINTEXT://kafka1:9092（容器内互通）+PLAINTEXT_HOST://192.168.1.10:9093（宿主机访问） - 通过
extra_hosts或自定义 Docker 网络确保容器名可解析，避免依赖 DNS
选择元数据服务：ZooKeeper 或 KRaft
当前主流仍用 ZooKeeper 集群管理 Kafka 元数据，3 节点 ZooKeeper 是高可用底线：
- ZooKeeper 需至少 3 实例（zoo1/zoo2/zoo3），启用
tickTime、initLimit、syncLimit等基础参数 - Kafka Broker 的
zookeeper.connect指向zoo1:2181,zoo2:2181,zoo3:2181 - 若尝试 KRaft 模式（跳过 ZooKeeper），需 Kafka ≥ 3.3，设置
process.roles=broker,controller、node.id、controller.quorum.voters，并禁用zookeeper.connect
配置副本与高可用关键参数
单靠多 Broker 不等于高可用，必须启用副本机制并合理设置：
- 创建 Topic 时指定
--replication-factor 3（副本数 ≤ Broker 数），并设--min-isr 2（最小同步副本数） - Broker 级配置：
default.replication.factor=3、num.partitions=3、unclean.leader.election.enable=false（禁止非 ISR 副本抢主，避免数据丢失） - 启用自动 Leader 平衡：
auto.leader.rebalance.enable=true，配合leader.imbalance.per.broker.percentage
验证与日常运维要点
部署后必须验证集群状态和故障转移能力：
- 用
kafka-topics.sh --describe检查每个 Partition 的 Leader 和 ISR 列表是否完整 - 手动
docker stop kafka2模拟节点宕机，观察其他 Broker 是否自动接管 Leader，Producer/Consumer 是否持续工作 - 日志挂载到宿主机（如
-v /data/kafka1:/var/lib/kafka/data），避免容器重建丢数据 - 监控
kafka-server-status、JMX 指标（如UnderReplicatedPartitions> 0 表示异常）
