We have use case where we need to manually calculate partition ID using the murmur2 partitioner from the librdkafka.
Rationale: we need to verify that messages received belongs to the right partition.
Since the desired function is not exposed to python via confluent_kafka, we have a workaround with using ctypes, see below.
But we still think the right approach is to use desired function (if available) via confluent_kafka module.
Description
We have use case where we need to manually calculate partition ID using the murmur2 partitioner from the librdkafka. Rationale: we need to verify that messages received belongs to the right partition.
Since the desired function is not exposed to python via
confluent_kafka, we have a workaround with usingctypes, see below. But we still think the right approach is to use desired function (if available) viaconfluent_kafkamodule.How to reproduce
Checklist
Please provide the following information:
confluent_kafka.version()andconfluent_kafka.libversion()): 2.3.0'debug': '..'as necessary) -