I've noticed a few exceptions in the logs like the one below, does it indicate data loss? should I worry about this? What is the possible reason for this to happen? I am using kafka 0.8.1.1
ERROR Closing socket for /xx.xxx.xxx.xxx because of error (kafka.network.Processor) kafka.common.KafkaException: Size of FileMessageSet /data/kafka/topic-name-11/00000000000014340499.log has been truncated during write: old size 26935, new size 0 at kafka.log.FileMessageSet.writeTo(FileMessageSet.scala:144) at kafka.api.PartitionDataSend.writeTo(FetchResponse.scala:69) at kafka.network.MultiSend.writeTo(Transmission.scala:102) at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:124) at kafka.network.MultiSend.writeTo(Transmission.scala:102) at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:219) at kafka.network.Processor.write(SocketServer.scala:375) at kafka.network.Processor.run(SocketServer.scala:247) at java.lang.Thread.run(Thread.java:745) ---------- Andrey Yegorov