TaiJuWu commented on code in PR #18329:
URL: https://github.com/apache/kafka/pull/18329#discussion_r1899112847
##########
core/src/main/scala/kafka/server/KafkaConfig.scala:
##########
@@ -665,16 +663,9 @@ class KafkaConfig private(doLog: Boolean, val props:
util.Map[_, _])
def saslMechanismControllerProtocol: String =
getString(KRaftConfigs.SASL_MECHANISM_CONTROLLER_PROTOCOL_CONFIG)
- def controlPlaneListener: Option[EndPoint] = {
- controlPlaneListenerName.map { listenerName =>
- listeners.filter(endpoint => endpoint.listenerName.value() ==
listenerName.value()).head
- }
- }
-
def dataPlaneListeners: Seq[EndPoint] = {
Review Comment:
file https://issues.apache.org/jira/browse/KAFKA-18362
##########
core/src/main/scala/kafka/network/SocketServer.scala:
##########
@@ -232,16 +199,14 @@ class SocketServer(
}
info("Enabling request processing.")
- controlPlaneAcceptorOpt.foreach(chainAcceptorFuture)
dataPlaneAcceptors.values().forEach(chainAcceptorFuture)
FutureUtils.chainFuture(CompletableFuture.allOf(authorizerFutures.values.toArray:
_*),
allAuthorizerFuturesComplete)
// Construct a future that will be completed when all Acceptors have been
successfully started.
// Alternately, if any of them fail to start, this future will be
completed exceptionally.
- val allAcceptors = dataPlaneAcceptors.values().asScala.toSeq ++
controlPlaneAcceptorOpt
val enableFuture = new CompletableFuture[Void]
-
FutureUtils.chainFuture(CompletableFuture.allOf(allAcceptors.map(_.startedFuture).toArray:
_*), enableFuture)
+
FutureUtils.chainFuture(CompletableFuture.allOf(dataPlaneAcceptors.values().asScala.toSeq.map(_.startedFuture).toArray:
_*), enableFuture)
Review Comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
