Storm uses Kryo to serialize Tuples. Check this
https://github.com/apache/storm/blob/master/storm-core/src/jvm/org/apache/storm/serialization/KryoTupleSerializer.java
Instead of serializing the entire tuple yourself may be you just want to
serialize the relevant values within the tuple.
Hello,
*1- Can anyone explain how to convert storm tuple to byte array. I have
used the following code. *
private byte[] convertToBytes(Object object) throws IOException {
try (ByteArrayOutputStream bos = new ByteArrayOutputStream();
ObjectOutput out = new ObjectOutputStream(bos)) {
Hi,
We are getting following exception in storm kafka spout. Workers are not
able to process any messages as it keeps restarting. We are running on
storm 0.9.6 version. Topology is running from last 1 year without any
issues. But, since last 2 days we started getting this exception. We tried
Hello, I am trying to set up a Storm cluster. I have setup one node to be
the zookeeper server, where I have installed zookeeper and started the
server.
I setup another instance to be nimbus. I added this machine's IP to
nimbus.seeds and added the zookeeper ip in the storm.yaml and ran storm
