[KAFKA-1735] MemoryRecords.Iterator needs to handle partial reads from compressed stream

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Guozhang Wang
• Reporter: Guozhang Wang
• Created: 27/Oct/14 23:55
• Updated: 17/May/16 14:15
• Resolved: 01/Jul/15 23:20

Description

Found a bug in the MemoryRecords.Iterator implementation, where

stream.read(recordBuffer, 0, size)

can read less than size'ed bytes, and rest of the recordBuffer would set to "\0".