Please take a look at KAFKA-4477 On Mon, Oct 30, 2017 at 2:06 AM, Yuanjia <yuanjia8...@163.com> wrote:
> Hi, > My cluster version is 0.10.0.0, 10 nodes. One server has many error > log, like that > java.io.IOException: Connection to 6 was disconnected before the response > was read > at kafka.utils.NetworkClientBlockingOps$$anonfun$ > blockingSendAndReceive$extension$1$$anonfun$apply$1.apply( > NetworkClientBlockingOps.scala:87) > at kafka.utils.NetworkClientBlockingOps$$anonfun$ > blockingSendAndReceive$extension$1$$anonfun$apply$1.apply( > NetworkClientBlockingOps.scala:84) > at scala.Option.foreach(Option.scala:257) > at kafka.utils.NetworkClientBlockingOps$$anonfun$ > blockingSendAndReceive$extension$1.apply(NetworkClientBlockingOps. > scala:84) > at kafka.utils.NetworkClientBlockingOps$$anonfun$ > blockingSendAndReceive$extension$1.apply(NetworkClientBlockingOps. > scala:80) > at kafka.utils.NetworkClientBlockingOps$.recursivePoll$2( > NetworkClientBlockingOps.scala:137) > at kafka.utils.NetworkClientBlockingOps$.kafka$utils$ > NetworkClientBlockingOps$$pollContinuously$extension( > NetworkClientBlockingOps.scala:143) > at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$ > extension(NetworkClientBlockingOps.scala:80) > at kafka.server.ReplicaFetcherThread.sendRequest( > ReplicaFetcherThread.scala:244) > at kafka.server.ReplicaFetcherThread.fetch( > ReplicaFetcherThread.scala:229) > at kafka.server.ReplicaFetcherThread.fetch( > ReplicaFetcherThread.scala:42) > at kafka.server.AbstractFetcherThread.processFetchRequest( > AbstractFetcherThread.scala:107) > at kafka.server.AbstractFetcherThread.doWork( > AbstractFetcherThread.scala:98) > at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63) > This server is running and on the zookeeper, but some topics are not > in ISR. > Has anyone meet the same problem? > > Regards > Yuanjia Li >