Fix bug causing random partitions with partition key

[deanchen]

Fixes #22

Force partition to be String since ArrayByte.hashcode != ArrayByte.hashcode

[deanchen]

Is there a status update on this? This is quite a serious issue since partitioning and therefore ordering does not work properly.

[joestein]

Hey @deanchen I am not sure what the issue is that you are talking about exactly. The change you made sets a new K but without changing the serializer. The way Kafka works is that you have a K,V record that gets put on a topic http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html which has a serializer either http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html or http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/Serializer.html or roll your own.

Maybe the issue you are seeing is caused by something else? Can you do a pull request with a test case or something that reproduces the issue succinctly please?