Skip to content

Commit

Permalink
More improvements.
Browse files Browse the repository at this point in the history
  • Loading branch information
[email protected] committed Dec 9, 2024
1 parent c6a617f commit e76f4ee
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -889,7 +889,7 @@ public Node leastLoadedNode(long now) {
List<Node> 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");
Expand Down

0 comments on commit e76f4ee

Please sign in to comment.