返回到文章

采纳

编辑于 2月前
123

leader中的数据损坏导致副本无法同步造成的单副本如何自动恢复

kafka

当leader broker 正常写入数据,但在副本同步的时候leader发生CRC检验错误抛出CorruptRecordException,进而导致follower无法正常同步。这造成后来写入的数据无法复制到follower造成单副本,并且消费者也无法正常消费数据,后来被生产的数据无法正常处理。

这往往出现在磁盘有一定损坏的情况下,对于以上问题目前只是通过人工更快的感应,并开启不洁选举切换leader恢复消费和同步。

目前使用的版本为1.1.1,在高版本中是否有对该问题更好的修复方法?