From e76f4eec04f75ff412f920c396dea327733a4027 Mon Sep 17 00:00:00 2001 From: "yuhayang@linkedin.com" Date: Mon, 9 Dec 2024 15:23:48 -0800 Subject: [PATCH] More improvements. --- .../src/main/java/org/apache/kafka/clients/NetworkClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java index 656aded59be91..db3c283fbe643 100644 --- a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java +++ b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java @@ -889,7 +889,7 @@ public Node leastLoadedNode(long now) { List nodes = this.metadataUpdater.fetchNodes(); if (nodes.isEmpty()) throw new IllegalStateException("metadataUpdater returned empty node list. " - + "The client is not able to connect to the cluster or there are no nodes in the Kafka cluster."); + + "The client is not able to connect to the Kafka cluster or there are no nodes in the Kafka cluster."); LeastLoadedNodeAlgorithm algo = this.leastLoadedNodeAlgorithm; if (algo == null) { throw new IllegalStateException("leastLoadedNodeAlgorithm cannot be null");