Hi, I created a KIP to help mitigate out of memory issues during down-conversion. The KIP proposes introducing a configuration that can prevent down-conversions altogether, and also describes a design for efficient memory usage for down-conversion.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-283%3A+Efficient+Memory+Usage+for+Down-Conversion Suggestions and feedback are welcome! Thanks, Dhruvil