This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch 1.1 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push: new 9996f2e KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) 9996f2e is described below commit 9996f2e167b05375822728c3dd5c0e5d767f01a9 Author: Rajini Sivaram <rajinisiva...@googlemail.com> AuthorDate: Thu May 10 22:17:59 2018 +0100 KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) --- core/src/main/scala/kafka/network/SocketServer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index c0bc593..8b2d402 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -146,10 +146,10 @@ class SocketServer(val config: KafkaConfig, val metrics: Metrics, val time: Time val securityProtocol = endpoint.securityProtocol val acceptor = new Acceptor(endpoint, sendBufferSize, recvBufferSize, brokerId, connectionQuotas) + addProcessors(acceptor, endpoint, processorsPerListener) KafkaThread.nonDaemon(s"kafka-socket-acceptor-$listenerName-$securityProtocol-${endpoint.port}", acceptor).start() acceptor.awaitStartup() acceptors.put(endpoint, acceptor) - addProcessors(acceptor, endpoint, processorsPerListener) } } -- To stop receiving notification emails like this one, please contact j...@apache.org.