Hi,
I am having trouble in getting my payload message back from the Kafka Message
in my consumer.
My producer is passing a byte[] stream Kafka.
If someone has an examle of how do I get the payload back, please share with
me. Really appreciate.
After iterating through the Kafka stream, I am
I am trying to build a POC with Kafka 0.8.1. I am using my own java class as a
Kafka message which has a bunch of String data types. For serializer.class
property in my producer, I cannot use the default serializer class or the
String serializer class that comes with Kafka library. I guess I
by using your own serializer ; through
kafka ().On the reciving side u can deseraialize from the byte[] and read
back your object.for using this you will have to
supply serializer.class=kafka.serializer.DefaultEncoder in the properties.
On Tue, May 20, 2014 at 4:23 PM, Kumar Pradeep kprad
