Hi,
Seeing below exceptions on broker id 3 node, in my three node kafka cluster.Also looks like this broker id is long under replicated and out of sync. [2016-04-06 04:00:00,720] ERROR [Replica Manager on Broker 3]: Error processing fetch operation on partition [subscribed_product_logs,2] offset 586475 (kafka.server.ReplicaManager)java.lang.IllegalStateException: Failed to read complete buffer for targetOffset 586475 startPosition 824825447 in /kafka/kafka-logs/<topic name>/00000000000000494997.log at kafka.log.FileMessageSet.searchFor(FileMessageSet.scala:133) at kafka.log.LogSegment.translateOffset(LogSegment.scala:105) at kafka.log.LogSegment.read(LogSegment.scala:126) at kafka.log.Log.read(Log.scala:506) at kafka.server.ReplicaManager$$anonfun$readFromLocalLog$1.apply(ReplicaManager.scala:536) at kafka.server.ReplicaManager$$anonfun$readFromLocalLog$1.apply(ReplicaManager.scala:507) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245) at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221) at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428) at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428) at scala.collection.TraversableLike$class.map(TraversableLike.scala:245) at scala.collection.AbstractTraversable.map(Traversable.scala:104) at kafka.server.ReplicaManager.readFromLocalLog(ReplicaManager.scala:507) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:462) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:431) at kafka.server.KafkaApis.handle(KafkaApis.scala:69) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60) at java.lang.Thread.run(Thread.java:745) Any help is appreciated. version is 0.9.0.1 Thanks,Mudit
