You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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) via
confluent_kafka
module.How to reproduce
Checklist
Please provide the following information:
confluent_kafka.version()
andconfluent_kafka.libversion()
): 2.3.0'debug': '..'
as necessary) -The text was updated successfully, but these errors were encountered: