@Test
    public void testExpireClosedConnectionWithPendingReceives() throws Exception {
        KafkaChannel channel = createConnectionWithPendingReceives(5);
        server.closeConnections();
        verifyChannelExpiry(channel);
    }
Verifies that a muted connection closed by peer is expired on idle timeout even if there are pending
receives on the socket.
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java