MSK集群Kafka Broker出现Fetch Request错误的原因及含义咨询

错误含义 #

该错误表示编号为1的Broker（作为副本节点）向编号为3的Leader Broker发起消息拉取请求时，连接失败。Fetch请求是Kafka集群维持数据一致性的核心机制：副本节点会定期向对应分区的Leader节点请求同步最新消息日志，一旦这个连接过程出现异常，就会触发该警告。

触发原因（结合你的集群状况） #

从你提供的全量日志来看，这个错误是集群磁盘耗尽引发的连锁反应：

• 磁盘满导致Broker服务异常：两个Broker出现No space left on device错误，说明它们的存储磁盘已完全耗尽。Kafka Broker在磁盘满时会停止所有写入操作，包括无法更新 checkpoint 文件，严重时会导致进程僵死、网络端口无法响应。
• Leader Broker 3不可用：你遇到的连接失败是Broker 1无法连接到Broker 3，而Broker 3正是那两个磁盘耗尽的Broker之一——它因磁盘满已无法正常提供服务，比如进程挂起、拒绝网络连接。
• 副本同步链路中断：当Leader Broker无法响应请求时，副本节点的Fetch请求自然无法完成，进而触发该警告。同时，集群的GroupCoordinator因Broker异常出现频繁Rebalance，进一步加剧了集群的不稳定。

总结 #

这个Fetch请求错误本质是集群内Broker因磁盘耗尽导致服务不可用，进而引发副本同步链路中断。解决核心是先为故障Broker释放或扩容磁盘空间，恢复Broker正常运行后，副本同步会自动重试，集群的Rebalance问题也会随之缓解。

内容的提问来源于stack exchange，提问作者Dushan