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.
