o
    `j*                     @   s:  d dl Z ddlmZmZ ddlmZ ddlmZmZm	Z	m
Z
mZmZ dZdZe dg d	Zd
eej ej_G dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd deZG dd  d eZG d!d" d"eZ eeeeee gZ!eeeeeegZ"G d#d$ d$eZ#G d%d& d&eZ$G d'd( d(eZ%G d)d* d*eZ&G d+d, d,eZ'G d-d. d.eZ(G d/d0 d0eZ)G d1d2 d2eZ*G d3d4 d4eZ+e(e)e*e+gZ,e$e%e&e'gZ-G d5d6 d6eZ.G d7d8 d8eZ/G d9d: d:eZ0G d;d< d<eZ1G d=d> d>eZ2G d?d@ d@eZ3G dAdB dBeZ4G dCdD dDeZ5G dEdF dFeZ6e3e4e5e6gZ7e/e0e1e2gZ8G dGdH dHeZ9G dIdJ dJeZ:G dKdL dLeZ;G dMdN dNeZ<G dOdP dPeZ=G dQdR dReZ>G dSdT dTeZ?G dUdV dVeZ@e=e>e?e@gZAe9e:e;e<gZBdS )W    N   )RequestResponse)Struct)ArrayBytesInt16Int32SchemaString GroupMember)	member_idgroup_instance_idmetadata)Nc                   @   sf   e Zd ZdZdZedefdefdedfdedfdedfd	e	dedfd
e
ffZdddZdS )JoinGroupResponse_v0   r   
error_codegeneration_idprotocol_nameutf-8leaderr   membersr   )group_protocol	leader_idN)__name__
__module____qualname__API_KEYAPI_VERSIONr
   r   r	   r   r   r   SCHEMAALIASES r#   r#   V/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/group.pyr      s"    




r   c                   @       e Zd ZdZdZejZejZdS )JoinGroupResponse_v1r   r   N)r   r   r   r   r    r   r!   r"   r#   r#   r#   r$   r&   "   
    
r&   c                   @   sh   e Zd ZdZdZedefdefdefdedfdedfd	edfd
e	d	edfde
ffZejZdS )JoinGroupResponse_v2r      throttle_time_msr   r   r   r   r   r   r   r   N)r   r   r   r   r    r
   r	   r   r   r   r   r!   r&   r"   r#   r#   r#   r$   r(   )   s     




r(   c                   @   r%   )JoinGroupResponse_v3r      N)r   r   r   r   r    r(   r!   r"   r#   r#   r#   r$   r+   :   r'   r+   c                   @   r%   )JoinGroupResponse_v4r      N)r   r   r   r   r    r+   r!   r"   r#   r#   r#   r$   r-   A   r'   r-   c                   @   sr   e Zd ZdZdZedefdefdefdedfdedfd	edfd
e	d	edfdedfde
ffZejZdS )JoinGroupResponse_v5r      r*   r   r   r   r   r   r   r   r   r   N)r   r   r   r   r    r
   r	   r   r   r   r   r!   r-   r"   r#   r#   r#   r$   r/   H   s"    





r/   c                
   @   sb   e Zd ZdZdZededfdefdedfdedfded	edfd
e	ffZ
ddddZdS )JoinGroupRequest_v0r   r   group_idr   session_timeout_msr   protocol_type	protocolsnamer   )groupsession_timeoutgroup_protocolsNr   r   r   r   r    r
   r   r	   r   r   r!   r"   r#   r#   r#   r$   r1   Z   s"    





r1   c                   @   sj   e Zd ZdZdZededfdefdefdedfdedfd	ed
edfde	ffZ
dddd	dZdS )JoinGroupRequest_v1r   r   r2   r   r3   rebalance_timeout_msr   r4   r5   r6   r   )r7   r8   rebalance_timeoutr9   Nr:   r#   r#   r#   r$   r;   m   s&    




r;   c                   @   r%   )JoinGroupRequest_v2r   r)   N)r   r   r   r   r    r;   r!   r"   r#   r#   r#   r$   r>      r'   r>   c                   @   r%   )JoinGroupRequest_v3r   r,   N)r   r   r   r   r    r>   r!   r"   r#   r#   r#   r$   r?      r'   r?   c                   @   r%   )JoinGroupRequest_v4r   r.   N)r   r   r   r   r    r?   r!   r"   r#   r#   r#   r$   r@      r'   r@   c                   @   sl   e Zd ZdZdZededfdefdefdedfdedfd	edfd
ededfde	ffZ
ejZdS )JoinGroupRequest_v5r   r0   r2   r   r3   r<   r   r   r4   r5   r6   r   N)r   r   r   r   r    r
   r   r	   r   r   r!   r@   r"   r#   r#   r#   r$   rA      s     





rA   c                   @   s,   e Zd ZedefdeedfdefZdS )ProtocolMetadataversionsubscriptionr   	user_dataN)	r   r   r   r
   r   r   r   r   r!   r#   r#   r#   r$   rB      s    rB   c                   @   s.   e Zd ZdZdZedefdefZddiZ	dS )SyncGroupResponse_v0   r   r   
assignmentmember_assignmentN)
r   r   r   r   r    r
   r   r   r!   r"   r#   r#   r#   r$   rF      s    rF   c                   @   s2   e Zd ZdZdZedefdefdefZ	e
jZdS )SyncGroupResponse_v1rG   r   r*   r   rH   N)r   r   r   r   r    r
   r	   r   r   r!   rF   r"   r#   r#   r#   r$   rJ      s    
rJ   c                   @   r%   )SyncGroupResponse_v2rG   r)   N)r   r   r   r   r    rJ   r!   r"   r#   r#   r#   r$   rK      r'   rK   c                   @   r%   )SyncGroupResponse_v3rG   r,   N)r   r   r   r   r    rK   r!   r"   r#   r#   r#   r$   rL      r'   rL   c                	   @   sV   e Zd ZdZdZededfdefdedfdededfde	ffZ
ddd	Zd
S )SyncGroupRequest_v0rG   r   r2   r   r   r   assignmentsrH   )r7   group_assignmentNr:   r#   r#   r#   r$   rM      s    


	
rM   c                   @   r%   )SyncGroupRequest_v1rG   r   N)r   r   r   r   r    rM   r!   r"   r#   r#   r#   r$   rP      r'   rP   c                   @   r%   )SyncGroupRequest_v2rG   r)   N)r   r   r   r   r    rP   r!   r"   r#   r#   r#   r$   rQ      r'   rQ   c                
   @   s\   e Zd ZdZdZededfdefdedfdedfdededfd	e	ffZ
ejZd
S )SyncGroupRequest_v3rG   r,   r2   r   r   r   r   rN   rH   N)r   r   r   r   r    r
   r   r	   r   r   r!   rQ   r"   r#   r#   r#   r$   rR      s    




	rR   c                   @   s:   e Zd ZedefdededfdeeffdefZ	dS )MemberAssignmentrC   rH   topicr   
partitionsrE   N)
r   r   r   r
   r   r   r   r	   r   r!   r#   r#   r#   r$   rS     s    

rS   c                   @       e Zd ZdZdZedefZdS )HeartbeatResponse_v0   r   r   Nr   r   r   r   r    r
   r   r!   r#   r#   r#   r$   rW   $      rW   c                   @   &   e Zd ZdZdZedefdefZdS )HeartbeatResponse_v1rX   r   r*   r   N	r   r   r   r   r    r
   r	   r   r!   r#   r#   r#   r$   r\   ,      r\   c                   @      e Zd ZdZdZejZdS )HeartbeatResponse_v2rX   r)   N)r   r   r   r   r    r\   r!   r#   r#   r#   r$   r`   5      
r`   c                   @   r_   )HeartbeatResponse_v3rX   r,   N)r   r   r   r   r    r`   r!   r#   r#   r#   r$   rb   ;  ra   rb   c                   @   s<   e Zd ZdZdZededfdefdedfZddiZ	dS )	HeartbeatRequest_v0rX   r   r2   r   r   r   r7   N)
r   r   r   r   r    r
   r   r	   r!   r"   r#   r#   r#   r$   rc   A  s    

rc   c                   @   r%   )HeartbeatRequest_v1rX   r   N)r   r   r   r   r    rc   r!   r"   r#   r#   r#   r$   rd   N  r'   rd   c                   @   r%   )HeartbeatRequest_v2rX   r)   N)r   r   r   r   r    rd   r!   r"   r#   r#   r#   r$   re   U  r'   re   c                   @   sD   e Zd ZdZdZededfdefdedfdedfZe	j
Z
dS )	HeartbeatRequest_v3rX   r,   r2   r   r   r   r   N)r   r   r   r   r    r
   r   r	   r!   re   r"   r#   r#   r#   r$   rf   \  s    



rf   c                   @   rV   )LeaveGroupResponse_v0   r   r   NrY   r#   r#   r#   r$   rg   r  rZ   rg   c                   @   r[   )LeaveGroupResponse_v1rh   r   r*   r   Nr]   r#   r#   r#   r$   ri   z  r^   ri   c                   @   r_   )LeaveGroupResponse_v2rh   r)   N)r   r   r   r   r    ri   r!   r#   r#   r#   r$   rj     ra   rj   c                	   @   sH   e Zd ZdZdZedefdefdede	dfde	dfdeffZ
d	S )
LeaveGroupResponse_v3rh   r,   r*   r   r   r   r   r   N)r   r   r   r   r    r
   r	   r   r   r   r!   r#   r#   r#   r$   rk     s    

rk   c                   @   s6   e Zd ZdZdZededfdedfZddiZdS )LeaveGroupRequest_v0rh   r   r2   r   r   r7   N)	r   r   r   r   r    r
   r   r!   r"   r#   r#   r#   r$   rl     s    

rl   c                   @   r%   )LeaveGroupRequest_v1rh   r   N)r   r   r   r   r    rl   r!   r"   r#   r#   r#   r$   rm     r'   rm   c                   @   r%   )LeaveGroupRequest_v2rh   r)   N)r   r   r   r   r    rm   r!   r"   r#   r#   r#   r$   rn     r'   rn   c                   @   sF   e Zd ZdZdZededfdededfdedffZe	j
Z
dS )	LeaveGroupRequest_v3rh   r,   r2   r   r   r   r   N)r   r   r   r   r    r
   r   r   r!   rn   r"   r#   r#   r#   r$   ro     s    



ro   )Ccollectionsapir   r   structr   typesr   r   r   r	   r
   r   DEFAULT_GENERATION_IDUNKNOWN_MEMBER_ID
namedtupler   len_fields__new____defaults__r   r&   r(   r+   r-   r/   r1   r;   r>   r?   r@   rA   JoinGroupRequestJoinGroupResponserB   rF   rJ   rK   rL   rM   rP   rQ   rR   SyncGroupRequestSyncGroupResponserS   rW   r\   r`   rb   rc   rd   re   rf   HeartbeatRequestHeartbeatResponserg   ri   rj   rk   rl   rm   rn   ro   LeaveGroupRequestLeaveGroupResponser#   r#   r#   r$   <module>   s     
		