[KAFKA-3773] SocketServer inflightResponses collection leaks memory on client disconnect

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0.0, 0.9.0.1
• Fix Version/s: 0.9.0.2
• Component/s: core
• Assignee: Jason Gustafson
• Reporter: Jason Gustafson
• Reviewer: Ismael Juma
• Created: 31/May/16 21:50
• Updated: 01/Jun/16 00:03
• Resolved: 01/Jun/16 00:03

Description

Prior to 0.10, we did not clean the inflightResponses collection maintained by each processor when a client disconnected. This causes a quickly growing memory leak since that collection maintains a reference to the pending response, which can be quite large in the case of fetches. This was fixed in KAFKA-3489 for 0.10, but we should ensure that 0.9 is patched as well.

Issue Links

• is related to: KAFKA-3489 Update request metrics if client closes connection while broker response is in flight
• links to: GitHub Pull Request #1452