kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999)
Date Thu, 10 May 2018 21:18:12 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 7ed7cca  KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999)
7ed7cca is described below

commit 7ed7cca4c9ee854432132a4fbf9be9d655dabbf2
Author: Rajini Sivaram <rajinisivaram@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 27d89b4..639f799 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
jgus@apache.org.

Mime
View raw message