[ https://issues.apache.org/jira/browse/KAFKA-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma resolved KAFKA-5250. -------------------------------- Resolution: Fixed > handleFetchRequest should do down conversion after throttling > ------------------------------------------------------------- > > Key: KAFKA-5250 > URL: https://issues.apache.org/jira/browse/KAFKA-5250 > Project: Kafka > Issue Type: Bug > Reporter: Ismael Juma > Assignee: Rajini Sivaram > Priority: Critical > Fix For: 0.11.0.0 > > > We currently do down conversion before throttling. This is good from the > perspective of getting the correct message size, but it means that we can > cause OOMs due to excessive memory retention. That is, by performing down > conversion, we are loading the records into the heap even though we are not > ready to send them yet. > It would be preferable to throttle before down conversion. > In addition, we currently updates bytesOut before throttling. We should do it > after throttling as well. -- This message was sent by Atlassian JIRA (v6.3.15#6346)