[KAFKA-870] hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7, 0.8.0
• Component/s: contrib
• Labels: patch
• Assignee: Unassigned
• Reporter: David Stein
• Created: 23/Apr/13 00:01
• Updated: 23/Apr/13 02:23
• Resolved: 23/Apr/13 02:22

Description

KafkaRecordWriter incorrectly gets the entire buffer capacity of the input BytesWritable.

If the capacity is larger than the underlying represented byte array, then the message will be padded with garbage bytes at the end.