From a95550bdec6ac91e41383acb1f4ef858ce412a1c Mon Sep 17 00:00:00 2001 From: huxihx Date: Thu, 4 Apr 2019 15:06:54 +0800 Subject: [PATCH] MINOR: Fix ThrottledReplicaListValidator doc error. --- core/src/main/scala/kafka/server/ConfigHandler.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/server/ConfigHandler.scala b/core/src/main/scala/kafka/server/ConfigHandler.scala index 5593225f0e6eb..5a33ea2af6b41 100644 --- a/core/src/main/scala/kafka/server/ConfigHandler.scala +++ b/core/src/main/scala/kafka/server/ConfigHandler.scala @@ -205,7 +205,7 @@ object ThrottledReplicaListValidator extends Validator { if (!(proposed.forall(_.toString.trim.matches("([0-9]+:[0-9]+)?")) || proposed.headOption.exists(_.toString.trim.equals("*")))) throw new ConfigException(name, value, - s"$name must be the literal '*' or a list of replicas in the following format: [partitionId],[brokerId]:[partitionId],[brokerId]:...") + s"$name must be the literal '*' or a list of replicas in the following format: [partitionId]:[brokerId],[partitionId]:[brokerId],...") } value match { case scalaSeq: Seq[_] => check(scalaSeq) @@ -214,6 +214,6 @@ object ThrottledReplicaListValidator extends Validator { } } - override def toString: String = "[partitionId],[brokerId]:[partitionId],[brokerId]:..." + override def toString: String = "[partitionId]:[brokerId],[partitionId]:[brokerId],..." }