Ouch. That can be a painful discovery after a client upgrade. It can
break a lot of app code.
I can see the reason for custom hash algorithm (lots of db products do
this, usually for stability, but sometimes for other hash properties
(Oracle has some cool guarantees around modifying number of part
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
wrote:
> Hello
>
> I am sending message from producer like this with DefaultEncoder.
>
> KeyedMessage keyedMessage = new KeyedMessage byte[]>("t
Hello
I am sending message from producer like this with DefaultEncoder.
KeyedMessage keyedMessage = new KeyedMessage("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
K
