Kafka节点故障原因
什么情况下Kafka会认为Broker视为故障呢?
- Kafka与zookeeper心跳为保持视为节点故障;
- Follower消息落后Leader太多也视为节点故障(落后标准:配置文件修改);
- Kafka会对故障节点进行移除;
Kafka节点故障处理
- Kafka基本不会因为节点故障而丢失数据(副本集保障和多个节点响应);
- 怎么保证不丢失? Kafka的语义担保(ACKS)也很大程度上避免数据丢失;
- Kafka会对消息进行集群内平衡,减少消息在某些节点热度过高(Leader和Follwer在同一台机器上);
- 多个Partition不会放在一个Broker上;
- 副本不会放在一个Broker上;