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. >
