You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ghosh, Achintya (Contractor)" <Ac...@comcast.com> on 2016/08/30 21:13:08 UTC

Kafka unable to process message

Hi there,

What does the below error mean and  how to avoid this? I see this error one of the kafkaServer.out file when other broker is down.

And not able to process any message as we see o.a.k.c.c.i.AbstractCoordinator - Issuing group metadata request to broker 5  from application log

[2016-08-30 20:40:28,621] WARN [ReplicaFetcherThread-0-3], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@8b198c3 (kafka.server.ReplicaFetcherThread)
java.io.IOException: Connection to psaq3-wc.sys.comcast.net:61616 (id: 3 rack: null) failed
       at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:63)
       at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$2.apply(NetworkClientBlockingOps.scala:59)
       at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:112)
       at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:120)
       at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:59)
       at kafka.server.ReplicaFetcherThread.sendRequest(ReplicaFetcherThread.scala:239)
       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)