请区分Kafka Leader(Broker)和Partition Leader。分区领导者也可以出现在追随者中。当我们向Kafka Broker发送消息时,它会根据分区直接将消息发送给Leader和Follower吗?
来自https://kafka.apache.org/documentation/#intro_distribution
每个分区都有一台充当“领导者”的服务器和零个或更多充当“跟随者”的服务器。领导者处理分区的所有读写请求,而追随者被动地复制领导者。
[编辑]
来自https://kafka.apache.org/documentation/#design_replicamanagment
优化领导选举流程也很重要,因为这是不可用的关键窗口。领导者选举的简单实现最终会在该节点发生故障时为该节点托管的所有分区运行每个分区的选举。相反,我们选择其中一位经纪人作为“控制人”。该控制器检测代理级别的故障,并负责更改故障代理中所有受影响分区的领导者。结果是,我们能够将许多所需的领导层变更通知批处理在一起,这使得大量分区的选举过程更加便宜且更快。如果控制器发生故障,幸存的代理之一将成为新的控制器。
| 归档时间: |
|
| 查看次数: |
4554 次 |
| 最近记录: |