@Test
    public void testExpireConnectionWithPendingReceives() throws Exception {
        KafkaChannel channel = createConnectionWithPendingReceives(5);
        verifyChannelExpiry(channel);
    }
Verify that if Selector#connect fails and throws an Exception, all related objects
are cleared immediately before the exception is propagated.
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java