diff --git clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
index a8101da..ad35e20 100644
--- clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
+++ clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
@@ -95,15 +95,6 @@ final class ClusterConnectionStates {
     }
 
     /**
-     * Return true iff we are in the process of connecting
-     * @param id The id of the connection
-     */
-    public boolean isConnecting(String id) {
-        NodeConnectionState state = nodeState.get(id);
-        return state != null && state.state == ConnectionState.CONNECTING;
-    }
-
-    /**
      * Enter the connected state for the given connection
      * @param id The connection identifier
      */
diff --git clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
index 12136d8..089dd02 100644
--- clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
+++ clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
@@ -175,6 +175,39 @@ public class NetworkClientTest {
         assertEquals("There should be NO leastloadednode", leastNode, null);
         
     }
+
+    @Test
+    public void testConnectionDelay() {
+        long now = time.milliseconds();
+        long delay = client.connectionDelay(node, now);
+
+        assertEquals(0, delay);
+    }
+
+    @Test
+    public void testConnectionDelay_connected() {
+        client.ready(node, time.milliseconds());
+        awaitReady(client, node);
+
+        long now = time.milliseconds();
+        long delay = client.connectionDelay(node, now);
+
+        assertEquals(Long.MAX_VALUE, delay);
+    }
+
+    @Test
+    public void testConnectionDelay_disconnected() {
+        client.ready(node, time.milliseconds());
+        awaitReady(client, node);
+
+        selector.close(node.idString());
+
+        client.poll(requestTimeoutMs, time.milliseconds());
+
+        long delay = client.connectionDelay(node, time.milliseconds());
+
+        assertEquals(reconnectBackoffMsTest, delay);
+    }
     
     private static class TestCallbackHandler implements RequestCompletionHandler {
         public boolean executed = false;