fix checkstyle error

linkedin · Nov 18, 2024 · b70fb07 · b70fb07
1 parent 1b25066
commit b70fb07
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...om/linkedin/kafka/cruisecontrol/monitor/sampling/CruiseControlMetricsReporterSampler.java b/...om/linkedin/kafka/cruisecontrol/monitor/sampling/CruiseControlMetricsReporterSampler.java
@@ -186,7 +186,7 @@ public void configure(Map<String, ?> configs) {
     _currentPartitionAssignment = Collections.emptySet();
 
     LOG.info("Waiting for metrics reporter topic [{}] to be available in the Kafka cluster.", _metricReporterTopic);
-    if (!CruiseControlMetricsUtils.retry(()->!this.isMetricsTopicExists(), 5, 1, metricTopicAssertAttempts)) {
+    if (!CruiseControlMetricsUtils.retry(() -> !this.isMetricsTopicExists(), 5, 1, metricTopicAssertAttempts)) {
         throw new IllegalStateException("Cruise Control cannot find the metrics reporter topic that matches [" + _metricReporterTopic
                                         + "] in the Kafka cluster.");
     }