[
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)
