This is an automated email from the ASF dual-hosted git repository.
cmccabe 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 d4fb388 MINOR: fix control plane listener + kraft error message
(#11729)
d4fb388 is described below
commit d4fb388583c1b0221ee22d75dbc364d95a7b2a2c
Author: Colin Patrick McCabe <[email protected]>
AuthorDate: Thu Feb 3 10:08:00 2022 -0800
MINOR: fix control plane listener + kraft error message (#11729)
The current error message suggests that controller.listener.names is a
replacement for
control.plane.listener.name. This is incorrect since these configurations
have very different
functions. This PR deletes the incorrect message.
Reviewers: David Jacot <[email protected]>, Kvicii
---
core/src/main/scala/kafka/server/KafkaConfig.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala
b/core/src/main/scala/kafka/server/KafkaConfig.scala
index 8621b24..3811fe6 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -2040,7 +2040,7 @@ class KafkaConfig private(doLog: Boolean, val props:
java.util.Map[_, _], dynami
}
def validateControlPlaneListenerEmptyForKRaft(): Unit = {
require(controlPlaneListenerName.isEmpty,
- s"${KafkaConfig.ControlPlaneListenerNameProp} is not supported in
KRaft mode. KRaft uses ${KafkaConfig.ControllerListenerNamesProp} instead.")
+ s"${KafkaConfig.ControlPlaneListenerNameProp} is not supported in
KRaft mode.")
}
def
validateAdvertisedListenersDoesNotContainControllerListenersForKRaftBroker():
Unit = {
require(!advertisedListenerNames.exists(aln =>
controllerListenerNames.contains(aln.value())),
