[ https://issues.apache.org/jira/browse/KAFKA-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Manikumar resolved KAFKA-407. ----------------------------- Resolution: Won't Fix This part of the code is removed. So closing the issue. > Uncaught InputStream.close() exception in CompressionUtils.compress() > --------------------------------------------------------------------- > > Key: KAFKA-407 > URL: https://issues.apache.org/jira/browse/KAFKA-407 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.7.1 > Reporter: Lorenzo Alberton > Priority: Minor > > In CompressionUtils.compress(), in this try/catch block: > ========== > try { > cf.write(messageByteBuffer.array) > } catch { > case e: IOException => error("Error while writing to the GZIP output > stream", e) > cf.close() > throw e > } finally { > cf.close() > } > ========== > cf.close() might throw an IOException, which is not handled. -- This message was sent by Atlassian JIRA (v6.4.14#64029)