How about upgrading to 0.10.1.1 or higher, as suggested by Ismael ? On Tue, Oct 31, 2017 at 3:42 AM, Yuanjia <yuanjia8...@163.com> wrote:
> Hi Ted, > It doesn't look like the same issue. > In my case, the node 6 doesn't shrink for the partitions it owns the > ISR's down to itself, and all clients work well. > I notice KAFKA-5153, it maybe same to mine. But it doesn't update for > a long time. > > > From: Ted Yu > Date: 2017-10-30 17:13 > To: users > Subject: Re: Servers Getting disconnected > 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 > > >
