9hXSSKJr SSKJrJr SSKJr "SS5r"SS5r"S S 5r "S S 5r "S S5r g))ConversionUtil)ConsumerGroupStateConsumerGroupType) AclOperationc"\rSrSrSrSSjrSrg)ConsumerGroupListinga Represents consumer group listing information for a group used in list consumer group operation. Used by :class:`ListConsumerGroupsResult`. Parameters ---------- group_id : str The consumer group id. is_simple_consumer_group : bool Whether a consumer group is simple or not. state : ConsumerGroupState Current state of the consumer group. type : ConsumerGroupType Type of the consumer group. NcXlX lUb [R"U[5UlUb![R"U[ 5UlggN)group_idis_simple_consumer_grouprconvert_to_enumrstatertype)selfr rrrs aC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/admin/_group.py__init__ConsumerGroupListing.__init__&sH (@%  '77?QRDJ  &66t=NODI )r rrrNN__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrr r s  Prr c"\rSrSrSrSSjrSrg)ListConsumerGroupsResult/a5 Represents result of List Consumer Group operation. Used by :meth:`AdminClient.list_consumer_groups`. Parameters ---------- valid : list(ConsumerGroupListing) List of successful consumer group listing responses. errors : list(KafkaException) List of errors encountered during the operation, if any. NcXlX lgr )validerrors)rr$r%s rr!ListConsumerGroupsResult.__init__<s   r)r%r$rrrrrr!r!/s  rr!c$\rSrSrSr/4SjrSrg)MemberAssignmentAz Represents member assignment information. Used by :class:`MemberDescription`. Parameters ---------- topic_partitions : list(TopicPartition) The topic partitions assigned to a group member. c:XlURc/Ulggr topic_partitions)rr,s rrMemberAssignment.__init__Ls! 0  ($&D ! )rr+Nrrrrr(r(As)+'rr(c"\rSrSrSrSSjrSrg)MemberDescriptionRa Represents member information. Used by :class:`ConsumerGroupDescription`. Parameters ---------- member_id : str The consumer id of the group member. client_id : str The client id of the group member. host: str The host where the group member is running. assignment: MemberAssignment The assignment of the group member target_assignment: MemberAssignment The target assignment of the group member group_instance_id : str The instance id of the group member. NcLXlX lX0lX@lX`lXPlgr ) member_id client_idhost assignmenttarget_assignmentgroup_instance_id)rr2r3r4r5r7r6s rrMemberDescription.__init__gs""" $!2!2r)r5r3r7r4r2r6rrrrrr/r/Rs (3rr/c:\rSrSrSrS\R 4SjrSrg)ConsumerGroupDescriptionpa Represents consumer group description information for a group used in describe consumer group operation. Used by :meth:`AdminClient.describe_consumer_groups`. Parameters ---------- group_id : str The consumer group id. is_simple_consumer_group : bool Whether a consumer group is simple or not. members: list(MemberDescription) Description of the members of the consumer group. partition_assignor: str Partition assignor. state : ConsumerGroupState Current state of the consumer group. type : ConsumerGroupType Type of the consumer group. coordinator: Node Consumer group coordinator. authorized_operations: list(AclOperation) AclOperations allowed for the consumer group. Nc pXlX lX0lSUlU(aD/UlUH7n URR [ R "U [55 M9 X@lUb [ R "U[5Ul Ub [ R "U[5Ul X`l gr )r rmembersauthorized_operationsappendrrrpartition_assignorrrrr coordinator) rr rr=r@rrAr>rops rr!ConsumerGroupDescription.__init__s (@% %)" )+D &+**11.2P2PQSUa2bc,#5  '77?QRDJ  &66t=NODI&r)r>rAr rr=r@rr) rrrrrrUNKNOWNrrrrrr:r:ps259?P?X?X'rr:N) _utilr_modelrr_aclrr r!r(r/r:rrrrHsD #:PP4$''"33<)')'r