Re: Weird encoder issue

2014-02-06 Thread Tom Amon
No. Based on the docs this seemed unnecessary. However, we tried this and it made no difference. We got the same error. I'm just confused why a change in the java version would have an effect on this... > Did you set both the key and the message encoder to DefaultEncoder? > Thanks, > Jun

Re: Weird encoder issue

2014-02-05 Thread Jun Rao
Did you set both the key and the message encoder to DefaultEncoder? Thanks, Jun On Wed, Feb 5, 2014 at 2:46 PM, Tom Amon wrote: > Hi, > > We have a functioning producer that uses as the Producer > and KeyedMessage signature. We specify the DefaultEncoder in the > properties. In Java 1.6 it w

Weird encoder issue

2014-02-05 Thread Tom Amon
Hi, We have a functioning producer that uses as the Producer and KeyedMessage signature. We specify the DefaultEncoder in the properties. In Java 1.6 it works fine. However, under Java 1.7 it gives the following error: Failed to collate messages by topic, partition due to: [B incompatible with j