Partitioner argument is not read about kt HOT 4 CLOSED

Also, I have tried to force the partitioner and I am not getting the same partition as the kafka java driver for example

from kt.

hi @vmaurin thanks for the feedback and thanks for the hint! i just pushed a commit to pass the partitioner argument along, would you mind testing it? to get the latest version:

go get -u github.com/fgeller/kt

from kt.

Thx for the quick fix. Partitioner option is taken in account now

For the mismatch with java partitioner, it seems it is using a different hashing algorithm
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java

Not having the same behavior is not really a "bug", but it will end with unexpected result if both kt and a standard kafka producer are used to produce on the same topic (no proper log compaction, unordered read for the same key)

from kt.

closing this for now, will document more details on #74 for the partitioner issue

from kt.