ChQSSKrSSKrSSKrSSKJrJr SSKJr SSKJ r SSK J r J r SSK Jr \R"\5r"SS\ 5rg) N)IterableMapping)ClusterMetadata)AbstractPartitionAssignor) ConsumerProtocolMemberAssignmentConsumerProtocolMemberMetadata)TopicPartitionc \rSrSrSrSrSr\S\S\ \ \ 4S\ \ \ 44Sj5r\S \\ S\ 4S j5r\S \ SS 4S j5rSrg )RoundRobinPartitionAssignora The roundrobin assignor lays out all the available partitions and all the available consumers. It then proceeds to do a roundrobin assignment from partition to consumer. If the subscriptions of all consumer instances are identical, then the partitions will be uniformly distributed. (i.e., the partition ownership counts will be within a delta of exactly one across all consumers.) For example, suppose there are two consumers C0 and C1, two topics t0 and t1, and each topic has 3 partitions, resulting in partitions t0p0, t0p1, t0p2, t1p0, t1p1, and t1p2. The assignment will be: C0: [t0p0, t0p2, t1p1] C1: [t0p1, t1p0, t1p2] When subscriptions differ across consumer instances, the assignment process still considers each consumer instance in round robin fashion but skips over an instance if it is not subscribed to the topic. Unlike the case when subscriptions are identical, this can result in imbalanced assignments. For example, suppose we have three consumers C0, C1, C2, and three topics t0, t1, t2, with unbalanced partitions t0p0, t1p0, t1p1, t2p0, t2p1, t2p2, where C0 is subscribed to t0; C1 is subscribed to t0, t1; and C2 is subscribed to t0, t1, t2. The assignment will be: C0: [t0p0] C1: [t1p0] C2: [t1p1, t2p0, t2p1, t2p2] roundrobinrclustermembersreturnc \[5nUR5HnURUR5 M /nUHNnUR U5nUc[ R SU5 M/UUVs/sHn[Xh5PM sn- nMP UR5 [R"S5n [R"[UR555n UH}n[U 5n UR X+R;a)[U 5n UR X+R;aM)XUR R#UR$5 M 0n UH5n ['UR([XR+55S5X'M7 U $s snf)Nz"No partition metadata for topic %sc6[R"[5$N) collections defaultdictlistnC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/coordinator/assignors/roundrobin.py4RoundRobinPartitionAssignor.assign..LsK++D1rr)setvaluesupdate subscriptionpartitions_for_topiclogwarningr sortrr itertoolscyclesortedkeysnexttopicappend partitionrversionitems) clsrr all_topicsmetadataall_topic_partitionsr) partitionsr+ assignment member_iter member_idprotocol_assignments rassign"RoundRobinPartitionAssignor.assign5s U (H   h33 4)68E 55erPs@-,M, !W ";W r