Issue in deserialize protostuff object in Kafka Consumer
<p>Getting following exception while deserializing byte[] into protostuff object in Kafka Consumer</p>

<pre><code>java.lang.NegativeArraySizeException
at com.dyuproject.protostuff.GraphIOUtil.mergeDelimitedFrom(GraphIOUtil.java:209)
at com.gme.protocols.protostuff.GmeTrade.readExternal(GmeTrade.java:2772)
at java.io.ObjectInputStream.readExternalData(Unknown Source)
at java.io.ObjectInputStream.readOrdinaryObject(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
</code></pre>

<p>Converted protostuff object to byte[] using following code.</p>

<pre><code>public static byte[] toBytes(Object o)
{
    try
    {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(baos);
        oos.writeObject(o);
        oos.close();
        byte[] b = baos.toByteArray();
        return b;
    }
    catch (IOException e)
    {
        return new byte[0];
    }
}
</code></pre>

<p>Sent that byte[] using Kafka producer with topic 'XX', where byte[] length is just 240.
Received that record using Kafka consumer. record.value().length (byte[]) length is same 240 what I sent from producer side.</p>

<p>Deserialized that byte[] to object using following code.</p>

<pre><code>public static Object fromBytes(byte[] bytes)
{
    try
    {
        return new ObjectInputStream(new ByteArrayInputStream(bytes)).readObject();
    }
    catch (Exception e)
    {
        e.printStackTrace();
        return null;
    }
}
</code></pre>

<p>Getting above mentioned exception. What I am doing wrong ? 
Using kafka_2.11-0.9.0.0 for your reference. Is there any other things needed? </p>