[STORM-1220] Avoid double copying in the Kafka spout

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Haohui Mai
• Reporter: Haohui Mai
• Created: 19/Nov/15 21:00
• Updated: 26/Nov/15 21:25
• Resolved: 26/Nov/15 21:25

Description

Currently the kafka spout takes a ByteBuffer from Kafka. However, the serialization scheme takes a byte[] array as input. Therefore the current implementation copies the ByteBuffer to a new byte[] array in order to hook everything together.

This jira proposes to changes the interfaces of serialization scheme to avoid copying the data twice in the spout.