You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/05/10 21:22:58 UTC
[kafka] branch 1.1 updated: KAFKA-6893;
Create processors before starting acceptor in SocketServer (#4999)
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 <ra...@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
jgus@apache.org.