o `jK @s0ddlZddlmZGdddeZddZdS)N) Partitionerc@seZdZdZddZdS)DefaultPartitionerzDefault partitioner. Hashes key to partition using murmur2 hashing (from java client) If key is None, selects partition randomly from available, or from all partitions if none are currently available c Csx||vr td|ft||}t||}|dur1t|} | dM} | t|;} || S|r5|n|} t | S)Nz%Topic %s not found in ClusterMetadatai) topics ValueErrorsortedpartitions_for_topiclistavailable_partitions_for_topicmurmur2lenrandomchoice) selftopickeyserialized_keyvalueserialized_valueclusterall_partitions availableidxpoolrW/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/partitioner/default.py partition s    zDefaultPartitioner.partitionN)__name__ __module__ __qualname____doc__rrrrrrs rc Cst|}d}d}d}||A}|d}t|D]\}|d}||dd@||dd@d>||d d@d >||d d@d>} | d M} | |9} | d M} | | d |?N} | d M} | |9} | d M} ||9}|d M}|| N}|d M}q|d} | d kr|||d@d d@d >N}|d M}| d kr|||d@dd@d>N}|d M}| dkr|||d@d@N}|d M}||9}|d M}||d d?N}|d M}||9}|d M}||d d?N}|d M}|S)zPure-python Murmur2 implementation. Based on java client, see org.apache.kafka.common.utils.Utils.murmur2 Args: data (bytes): opaque bytes Returns: MurmurHash2 of data l2.i[rrll )r range) datalengthseedmrhlength4ii4k extra_bytesrrrr sZ   r )r abcrrr rrrrs