reverting changes

linkedin · Sep 26, 2024 · 32c97b0 · 32c97b0
1 parent 09bd21b
commit 32c97b0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java b/clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
@@ -909,7 +909,7 @@ public Node leastLoadedNode(long now) {
             }
 
             if (newNodes.size() == 0) {
-                // return null;
+                return null;
             }
 
             int offset = this.randOffset.nextInt(newNodes.size());

diff --git a/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java b/clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
@@ -630,7 +630,6 @@ public void testThrottlingNotEnabledForConnectionToOlderBroker() {
         assertEquals(0, client.throttleDelayMs(node, time.milliseconds()));
     }
 
-/*
     @Test
     public void noLeastLoadedNode() {
         NetworkClient nc = new NetworkClient(selector, metadataUpdater, "mock", Integer.MAX_VALUE,
@@ -643,7 +642,7 @@ public void noLeastLoadedNode() {
 
         assertEquals(null, nc.leastLoadedNode(time.milliseconds()));
     }
-*/
+
     private int sendEmptyProduceRequest() {
         return sendEmptyProduceRequest(node.idString());
     }