[KAFKA-6716] discardChannel should be released in MockSelector#completeSend

• Type: Test
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Assignee: huxihx
• Reporter: Ted Yu
• Created: 26/Mar/18 18:23
• Updated: 25/Apr/18 09:42
• Resolved: 03/Apr/18 06:44

Description

    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);
    }

The discardChannel should be closed before returning from the method

Issue Links

• links to: GitHub Pull Request #4783