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 On Wed, Feb 5, 2014 at 2:46 PM, Tom Amon <ta46...@gmail.com> wrote: > Hi, > > We have a functioning producer that uses <byte[], byte[]> 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 java.lang.String > > If we change the signature to <String, String>, change the byte arrays > we're passing to strings, and change the encoder to StringEncoder then > things work just fine. > > Has anyone encountered something like this before? > > Thanks. >
