KafkaException Size of FileRecords has been truncated during write: old size 4754, new size 0

[2021-08-24 14:33:52,938] WARN [SocketServer brokerId=1] Unexpected error from /172.16.25.248; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.KafkaException: Size of FileRecords /var/lib/kafka/data/station_frame_messages-0/00000000000051038050.log has been truncated during write: old size 4754, new size 0
at org.apache.kafka.common.record.FileRecords.writeTo(FileRecords.java:277)
at org.apache.kafka.common.record.DefaultRecordsSend.writeTo(DefaultRecordsSend.java:33)
at org.apache.kafka.common.record.RecordsSend.writeTo(RecordsSend.java:58)
at org.apache.kafka.common.record.MultiRecordsSend.writeTo(MultiRecordsSend.java:93)
at org.apache.kafka.common.network.KafkaChannel.write(KafkaChannel.java:425)
at org.apache.kafka.common.network.Selector.write(Selector.java:644)
at org.apache.kafka.common.network.Selector.attemptWrite(Selector.java:637)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:593)
at org.apache.kafka.common.network.Selector.poll(Selector.java:481)

你好,我是有问必答小助手。为了技术专家团更好地为您解答问题,烦请您补充下(1)问题背景详情,(2)您想解决的具体问题,(3)问题相关代码图片或者报错信息。便于技术专家团更好地理解问题,并给出解决方案。


您可以点击问题下方的【编辑】,进行补充修改问题。