[KAFKA-746] Snappy compression isn't applied to messages written to disk on broker

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.7.2
• Component/s: producer
• Assignee: Jun Rao
• Reporter: Esko Suomi
• Created: 31/Jan/13 15:21
• Updated: 05/Dec/16 12:52
• Resolved: 05/Dec/16 12:52

Description

We recently tested 0.7.2 performance using different compression codecs for messages and noticed that when using Snappy (compression.codec = 2 in Producer configuration) the messages written to topic partitions were written without compression. Compared to GZIP (compression.codec = 1) this is especially peculiar since with GZIP the partition files themselves were compressed as expected.

I did walk through the 0.8 code briefly and didn't spot any obvious reasons why this would be happening so I'm now handing this issue completely into your able hands.