Message Encoding in Kafka 0.8

2013-07-20 Thread prashant amar
I noticed that ProducerData has been removed in 0.8 branch If I'd wish to send a complex message type (encoded message) , how would I do it in 0.8? In 0.7.X (a snippet from Neha's example) val producer = new Producer[Message, MemberRecord](config); // send a single message val mes

Re: Message Encoding in Kafka 0.8

2013-07-20 Thread prashant amar
Hello, Specified below is my code base where I am attempting to marshall a complex type and receiving the follow error. Am I missing anything here? Sending Encoded Messages .. [error] (run-main) java.lang.ClassCastException: java.lang.String cannot be cast to com.test.groups.MemberRecord java.la

Re: Message Encoding in Kafka 0.8

2013-07-20 Thread prashant amar
Can anybody please help with this issue indicated below. I have not heard from anyone with a solution. Thanks in advance Amar On Tue, Jul 16, 2013 at 11:35 PM, prashant amar wrote: > Hello, > > Specified below is my code base where I am attempting to marshall a > complex type and receiving the