9h &SSKr"SS5rSrg)Nc(\rSrSrSr\S5rSrg)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 cUc3U(a[R"U5$[R"U5$[U5nUS-nU[U5-nX$$)a  Get the partition corresponding to key :param key: partitioning key :param all_partitions: list of all partitions sorted by partition ID :param available: list of available partitions in no particular order :return: one of the values from all_partitions or available i)randomchoicemurmur2len)clskeyall_partitions availableidxs YC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/partitioner.py__call__DefaultPartitioner.__call__ sU ;}}Y//==0 0cl z s>""""N)__name__ __module__ __qualname____firstlineno____doc__ classmethodr__static_attributes__rrrrrs##rrcR[U5nSnSnSnX!- nUS-n[U5HtnUS-nXS-S-XS-S-S--XS -S-S --XS -S-S--n U S -n X-n U S -n XS -U- -n U S -n X-n U S -n XS-nUS -nXY-nUS -nMv US-n U S :aXPUS-S -S-S --nUS -nU S :aXPUS-S-S-S--nUS -nU S:aXPUS-S--nUS -nXS-nUS -nXUS -S- -nUS -nXS-nUS -nXUS -S- -nUS -nU$)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_bytess rr r !sYF D A A AkG 7^ U q&\D !V t#) +!V t#* ,!V t#* , Z  Z +o! ## Z  Z  Z  Z',1*Ka FRK1$%, 33 Za FRK1$%, 22 Za &2+  %% Z  Zk/b  AOAFAOAk/b  AOA Hr)rrr rrrr3s ##:? r