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)
