9hSSKrSSKrSSKJrJr SSKJr SSKJrJ r \R"\ 5r "SS\R5rg)N)IterableMapping)ClusterMetadata) ConsumerProtocolMemberAssignmentConsumerProtocolMemberMetadatac \rSrSrSr\\RS\4Sj55r \ \RS\ S\ \\ 4S\\\44Sj55r\ \RS\\S\ 4S j55r\ \RS \SS 4S j55rS rg )AbstractPartitionAssignorzAbstract assignor implementation which does some common grunt work (in particular collecting partition counts which are always needed in assignors). returncg)z1.name should be a string identifying the assignorN)selfs lC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/coordinator/assignors/abstract.pynameAbstractPartitionAssignor.nameclustermemberscg)a/Perform group assignment given cluster metadata and member subscriptions Arguments: cluster (ClusterMetadata): metadata for use in assignment members (dict of {member_id: MemberMetadata}): decoded metadata for each member in the group. Returns: dict: {member_id: MemberAssignment} Nr )clsrrs rassign AbstractPartitionAssignor.assignrrtopicscg)zGenerate ProtocolMetadata to be submitted via JoinGroupRequest. Arguments: topics (set): a member's subscribed topics Returns: MemberMetadata struct Nr )rrs rmetadata"AbstractPartitionAssignor.metadata*rr assignmentNcg)zCallback that runs on each assignment. This method can be used to update internal state, if any, of the partition assignor. Arguments: assignment (MemberAssignment): the member's assignment Nr )rrs r on_assignment'AbstractPartitionAssignor.on_assignment6rrr )__name__ __module__ __qualname____firstlineno____doc__propertyabcabstractmethodstrr classmethodrrrdictrrrrr __static_attributes__r rrr r s@c@@   <<=  c33 4    hsm 0N   'G D  rr )r(loggingcollections.abcrraiokafka.clusterraiokafka.coordinator.protocolrr getLoggerr"logABCr r rrr5s8 -, !2 2 r