@Override
                    public void close() throws IOException {
                        closedChannelsCount.getAndIncrement();
                        super.close();
                        if (index == 0) throw new RuntimeException("you should fail");
                    }
Validate that we can send and receive a message larger than the receive and send buffer size
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java