kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ghosh, Achintya (Contractor)" <Achintya_Gh...@comcast.com>
Subject Kafka unable to process message
Date Tue, 30 Aug 2016 21:13:08 GMT
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)

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message