[
https://issues.apache.org/jira/browse/KAFKA-13107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fuud updated KAFKA-13107:
-------------------------
Description:
kafka.network.Acceptor#serverChannel is not closed if KafkaServer.startup is
failed with zk error.
Because the single point where serverChannel.close() is
kafka/network/SocketServer.scala:640 but it requires Acceptor to be scheduled.
It is regression: in 2.5 server channel was closed as expected.
Reproduced in 2.8
was:
kafka.network.Acceptor#serverChannel is not closed if KafkaServer.startup is
failed with zk error.
Because the single point where serverChannel.close() is
kafka/network/SocketServer.scala:640 but it requires Acceptor to be scheduled.
It is regression: in 2.5 server channel was closed as expected.
> KafkaServer.startup leaves server socket open if zk error is throws (ex.
> NodeExists)
> ------------------------------------------------------------------------------------
>
> Key: KAFKA-13107
> URL: https://issues.apache.org/jira/browse/KAFKA-13107
> Project: Kafka
> Issue Type: Bug
> Reporter: Fuud
> Priority: Major
>
> kafka.network.Acceptor#serverChannel is not closed if KafkaServer.startup is
> failed with zk error.
> Because the single point where serverChannel.close() is
> kafka/network/SocketServer.scala:640 but it requires Acceptor to be scheduled.
> It is regression: in 2.5 server channel was closed as expected.
> Reproduced in 2.8
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)