[jira] [Created] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

["Ted Yu (JIRA)" <ji...@apache.org>]

Ted Yu created KAFKA-6716:
-----------------------------

             Summary: discardChannel should be released in MockSelector#completeSend
                 Key: KAFKA-6716
                 URL: https://issues.apache.org/jira/browse/KAFKA-6716
             Project: Kafka
          Issue Type: Test
            Reporter: Ted Yu


{code}
    private void completeSend(Send send) throws IOException {
        // Consume the send so that we will be able to send more requests to the destination
        ByteBufferChannel discardChannel = new ByteBufferChannel(send.size());
        while (!send.completed()) {
            send.writeTo(discardChannel);
        }
        completedSends.add(send);
    }
{code}
The {{discardChannel}} should be closed before returning from the method



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)