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");