ERROR [kafka-request-handler-7] 2015-10-20 05:06:52,521 Logging.scala kafka.server.KafkaApis [KafkaApi-164] error when handling request Name: FetchRequest; Version: 0; CorrelationId: 28096576; ClientId: ReplicaFetcherThread-0-164; ReplicaId: 135; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [deal_contact_people,0] -> PartitionFetchInfo(247334,10485760),[product_templates,0] -> PartitionFetchInfo(944,10485760), ... <many other requests rtuncated>
kafka.common.NotAssignedReplicaException: Leader 164 failed to record follower 135's position 2826 for partition [facts.bi,0] since the replica 135 is not recognized to be one of the assigned replicas 164,163,155 for partition [facts.bi,0]
    at kafka.cluster.Partition.updateLeaderHWAndMaybeExpandIsr(Partition.scala:231)
    at kafka.server.ReplicaManager.recordFollowerPosition(ReplicaManager.scala:432)
    at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHw$2.apply(KafkaApis.scala:460)
    at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHw$2.apply(KafkaApis.scala:458)
    at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:224)
    at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:403)
    at kafka.server.KafkaApis.maybeUpdatePartitionHw(KafkaApis.scala:458)
    at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:424)
    at kafka.server.KafkaApis.handle(KafkaApis.scala:186)
    at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
    at java.lang.Thread.run(Thread.java:745)