首页/数据/数据工程与 ETL 速查/分区 Leader 选举与均衡
本包目录(311 条)
管道基础52 条
Kafka64 条
调度与编排40 条数仓建模52 条数据质量50 条CDC 与同步53 条

分区 Leader 选举与均衡

Leader 分布不均时可用 PREFERRED 选举把分区首领迁回首选副本;当所有 ISR 副本都不可用时,才考虑 UNCLEAN 选举,但会丢未同步数据。

PREFERRED把 leader 迁回 replicas 列表首位副本,用于负载均衡
UNCLEANISR 全部不可用时从非同步副本选主,可能丢数据
范围--all-topic-partitions 或 --topic + --partition

首选副本选举与单分区选举

首选副本选举与单分区选举
kafka-leader-election.sh --bootstrap-server localhost:9092 \
  --election-type PREFERRED --all-topic-partitions

kafka-leader-election.sh --bootstrap-server localhost:9092 \
  --election-type PREFERRED --topic orders --partition 0
UNCLEAN 选举是数据安全上的最后手段:接受该分区丢失尚未同步的消息时才使用。

易错点

  • 选举是轻量操作但不等于负载自动均衡,长期均衡仍要规划副本分布
  • 对大量分区同时触发选举会加重 controller 负担,分批执行

数据来源与参考

  • Apache Kafka 官方文档:Kafka Leader Election 与 kafka-leader-election.sh
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌