You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "huxi (JIRA)" <ji...@apache.org> on 2016/11/22 03:31:59 UTC
[jira] [Commented] (KAFKA-4428) Kafka does not exit when it
receives "Address already in use" error during startup
[ https://issues.apache.org/jira/browse/KAFKA-4428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685562#comment-15685562 ]
huxi commented on KAFKA-4428:
-----------------------------
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)