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 b13391e MINOR: Update the javadoc of SocketServer#startup(). (#7215)
b13391e is described below
commit b13391e0fe0b249d46e47d886fbdafaaed7c1eef
Author: David Jacot <dja...@confluent.io>
AuthorDate: Thu Aug 15 09:53:56 2019 -0700
MINOR: Update the javadoc of SocketServer#startup(). (#7215)
Update the javadoc of SockerServer#startup().
SocketServer#startProcessors() does not exist any more and it has been replaced
by SocketServer#startDataPlaneProcessors() and
SocketServer#startControlPlaneProcessor().
Reviewers: Jason Gustafson <ja...@confluent.io>
---
core/src/main/scala/kafka/network/SocketServer.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/network/SocketServer.scala
b/core/src/main/scala/kafka/network/SocketServer.scala
index 69f02ae..0ebded8 100644
--- a/core/src/main/scala/kafka/network/SocketServer.scala
+++ b/core/src/main/scala/kafka/network/SocketServer.scala
@@ -103,7 +103,8 @@ class SocketServer(val config: KafkaConfig,
/**
* Start the socket server. Acceptors for all the listeners are started.
Processors
* are started if `startupProcessors` is true. If not, processors are only
started when
- * [[kafka.network.SocketServer#startProcessors()]] is invoked. Delayed
starting of processors
+ * [[kafka.network.SocketServer#startDataPlaneProcessors()]] or
+ * [[kafka.network.SocketServer#startControlPlaneProcessor()]] is invoked.
Delayed starting of processors
* is used to delay processing client connections until server is fully
initialized, e.g.
* to ensure that all credentials have been loaded before authentications
are performed.
* Acceptors are always started during `startup` so that the bound port is
known when this
