在Kafka集群中,Broker Failure指的是Broker节点发生故障而无法提供服务的情况。
这可能导致以下影响:
1. 数据丢失
如果这个Broker宕机前没有来得及同步数据到其他副本,那么存储在这个broker上的消息就可能会丢失。
2. 不可用的partition
如果一个partition的Leader宕机,这个partition就会变得不可用。
直到重新选举新的Leader。
3. 不可写
那些 assigned 到这个Broker上的partition就无法向其写入数据了。
4. 不可读
存储在这个Broker上的partition也无法被消费者读取。
5. ISR变化
这个Broker将退出ISR列表。
6. Partition迁移
需要重新分配这个Broker上的partition到其他节点。
Broker Failure主要表现为:
- 数据可能会丢失
- 某些partition会变为不可用
- 不可写
- 不可读
- ISR会变化
- 需要重新分配partition
这种情况需要根据副本策略以及及时的监控和故障转移来减少对业务的影响。
Broker Failure主要会导致部分partition变为不可用、不可写、不可读,需要重新分配partition到其他节点上。可能造成部分数据丢失。