Kafka-node: CyclicPartitioner, RandomPartitioner, and KeyedPartitioner do not work properly.

Created on 9 Aug 2016  路  1Comment  路  Source: SOHU-Co/kafka-node

Partitioners do not receive list of partitions parameter and as the result:
CyclicPartitioner always returns 0
KeyedPartitioner and RandomPartitioner fail

picture milashenko

Most helpful comment

call client.refreshMetadata([topic1, topic2], callback) before sending.

picture hyperlink on 9 Aug 2016
🎉2 👍2

>All comments

call client.refreshMetadata([topic1, topic2], callback) before sending.

hyperlink picture hyperlink on 9 Aug 2016
🎉2 👍2
Was this page helpful?
0 / 5 - 0 ratings

Related issues

ghinks picture ghinks  路  6Comments
nithjino picture nithjino  路  3Comments
sergeyjsg picture sergeyjsg  路  4Comments
AnnisaNurika picture AnnisaNurika  路  5Comments
juhanishen picture juhanishen  路  7Comments