Hi
Your key seems to be String.
key.serializer.class might need to be set to StringEncoder.
regards
On Sat, Apr 25, 2015 at 10:43 AM, Gaurav Agarwal <gaurav130...@gmail.com>
wrote:
> Hello
>
> I am sending message from producer like this with DefaultEncoder.
>
> KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String,
> byte[]>("topic",Serializations.serialize("s"),
>
> Serializations.getSerialized(msg,rqst));
>
> This is a compile time error at java level as it expects String
>
>
> But if i use
>
>
> KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String,
> byte[]>("topic","s",Serializations.getSerialized(msg,rqst));
>
>
> as part of sending message , it gives me class cast exception as i have
> configured DefaultEncoder and sending byte Message.
>
--
http://khangaonkar.blogspot.com/
