You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by "Haohui Mai (JIRA)" <ji...@apache.org> on 2015/11/19 22:01:11 UTC

[jira] [Created] (STORM-1220) Avoid double copying in the Kafka spout

Haohui Mai created STORM-1220:
---------------------------------

             Summary: Avoid double copying in the Kafka spout
                 Key: STORM-1220
                 URL: https://issues.apache.org/jira/browse/STORM-1220
             Project: Apache Storm
          Issue Type: Bug
            Reporter: Haohui Mai
            Assignee: Haohui Mai


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)