Tom Amon 2014-02-05, 22:46
Jun Rao 2014-02-06, 05:54
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
> Did you set both the key and the message encoder to DefaultEncoder?
On Wed, Feb 5, 2014 at 2:46 PM, Tom Amon <[EMAIL PROTECTED]> wrote:
> 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?