[KAFKA-407] Uncaught InputStream.close() exception in CompressionUtils.compress()

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Won't Fix
• Affects Version/s: 0.7.1
• Component/s: core
• Assignee: Unassigned
• Reporter: Lorenzo Alberton
• Created: 18/Jul/12 19:06
• Updated: 30/Oct/17 12:14
• Resolved: 30/Oct/17 12:14

Description

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.