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.
Attachments
Issue Links
- is related to
-
KAFKA-3489 Update request metrics if client closes connection while broker response is in flight
-
- Resolved
-
- links to
