Thanks Stig,
So I tried using
>> .setValue(EmailObjectDeserializer.class)
and the EmailObjectDeserializer class is implementing the interface
org.apache.storm.kafka.spout.SerializableDeserializer
>> public class EmailObjectDeserializer implements SerializableDeserializer
{...}
I see the
Hey! I've been struggling getting logviewer to work in storm 1.1.1 and was
wondering if anyone could lend a hand w/ the required configuration and
help me understand where I've gone wrong.
First of all I have the logviewer daemon running on every supervisor host.
Second I've modified the
