From e2d325ee4cd15eb4df10af59b5f8f42eca52a269 Mon Sep 17 00:00:00 2001 From: Kowshik Prakasam Date: Wed, 4 Nov 2020 23:01:20 -0800 Subject: [PATCH] MINOR: Fix comment in FinalizedFeatureChangeListener.initOrThrow (#9562) Fixed the param doc in FinalizedFeatureChangeListener.initOrThrow method. The parameter waitOnceForCacheUpdateMs is expected to be > 0, but the doc was incorrect. Reviewers: Chia-Ping Tsai --- .../scala/kafka/server/FinalizedFeatureChangeListener.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala b/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala index 40bce240d2a32..ac4600fa42a60 100644 --- a/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala +++ b/core/src/main/scala/kafka/server/FinalizedFeatureChangeListener.scala @@ -207,7 +207,7 @@ class FinalizedFeatureChangeListener(private val finalizedFeatureCache: Finalize * will exit eventually. * * @param waitOnceForCacheUpdateMs # of milli seconds to wait for feature cache to be updated once. - * If this parameter <= 0, no wait operation happens. + * (should be > 0) * * @throws Exception if feature incompatibility check could not be finished in a timely manner */