[ https://issues.apache.org/jira/browse/KAFKA-4428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685562#comment-15685562 ]
huxi edited comment on KAFKA-4428 at 11/22/16 3:32 AM: ------------------------------------------------------- During Acceptor initialization, if "Address already in use" error is encountered, the countdown latch for all Processors instsance have no chance to be counted down, hence Kafka server fails to exit, pending when invoking Processor.shutdown was (Author: huxi_2b): During Acceptor initialization, if "Address already in use" error is encountered, the countdown latch for all Processors instsance have no change to be counted down, hence Kafka server fails to exit, pending when invoking Processor.shutdown > Kafka does not exit when it receives "Address already in use" error during > startup > ---------------------------------------------------------------------------------- > > Key: KAFKA-4428 > URL: https://issues.apache.org/jira/browse/KAFKA-4428 > Project: Kafka > Issue Type: Bug > Components: network > Affects Versions: 0.10.1.0 > Reporter: Zeynep Arikoglu > Assignee: huxi > > [2016-11-21 14:58:04,136] FATAL [Kafka Server 0], Fatal error during > KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) > kafka.common.KafkaException: Socket server failed to bind to 0.0.0.0:5000: > Address already in use. > at kafka.network.Acceptor.openServerSocket(SocketServer.scala:316) > at kafka.network.Acceptor.<init>(SocketServer.scala:242) > at > kafka.network.SocketServer$$anonfun$startup$1.apply(SocketServer.scala:96) > at > kafka.network.SocketServer$$anonfun$startup$1.apply(SocketServer.scala:89) > at scala.collection.Iterator$class.foreach(Iterator.scala:893) > at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) > at > scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206) > at kafka.network.SocketServer.startup(SocketServer.scala:89) > at kafka.server.KafkaServer.startup(KafkaServer.scala:219) > at > kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39) > at kafka.Kafka$.main(Kafka.scala:67) > at kafka.Kafka.main(Kafka.scala) > Caused by: java.net.BindException: Address already in use > at sun.nio.ch.Net.bind0(Native Method) > at sun.nio.ch.Net.bind(Net.java:433) > at sun.nio.ch.Net.bind(Net.java:425) > at > sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223) > at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) > at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67) > at kafka.network.Acceptor.openServerSocket(SocketServer.scala:312) > ... 11 more > [2016-11-21 14:58:04,138] INFO [Kafka Server 0], shutting down > (kafka.server.KafkaServer) > [2016-11-21 14:58:04,146] INFO [Socket Server on Broker 0], Shutting down > (kafka.network.SocketServer) -- This message was sent by Atlassian JIRA (v6.3.4#6332)