o
    `šjª'  ã                   @   s<  d dl mZmZ d dlmZmZmZmZmZm	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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eegZe
e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$G d5d6„ d6eƒZ%G d7d8„ d8eƒZ&G d9d:„ d:eƒZ'e"e#e$e%e&e'gZ(eeeee e!gZ)d;S )<é   )ÚRequestÚResponse)ÚArrayÚInt16ÚInt32ÚInt64ÚSchemaÚStringc                	   @   s@   e Zd ZdZdZedededƒfdedefde	fƒfƒfƒZ
d	S )
ÚOffsetCommitResponse_v0é   é    ÚtopicsÚnameúutf-8Ú
partitionsÚpartition_indexÚ
error_codeN)Ú__name__Ú
__module__Ú__qualname__ÚAPI_KEYÚAPI_VERSIONr   r   r	   r   r   ÚSCHEMA© r   r   úW/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/commit.pyr
      s    
þþÿr
   c                   @   ó   e Zd ZdZdZejZdS )ÚOffsetCommitResponse_v1r   r   N)r   r   r   r   r   r
   r   r   r   r   r   r      ó    
r   c                   @   r   )ÚOffsetCommitResponse_v2r   é   N)r   r   r   r   r   r   r   r   r   r   r   r      r   r   c                
   @   sF   e Zd ZdZdZedefdededƒfdedefd	e	fƒfƒfƒZ
d
S )ÚOffsetCommitResponse_v3r   é   Úthrottle_time_msr   r   r   r   r   r   N)r   r   r   r   r   r   r   r   r	   r   r   r   r   r   r   r       s    
þþþr    c                   @   r   )ÚOffsetCommitResponse_v4r   é   N)r   r   r   r   r   r    r   r   r   r   r   r#   *   r   r#   c                   @   r   )ÚOffsetCommitResponse_v5r   é   N)r   r   r   r   r   r#   r   r   r   r   r   r%   0   r   r%   c                   @   r   )ÚOffsetCommitResponse_v6r   é   N)r   r   r   r   r   r%   r   r   r   r   r   r'   6   r   r'   c                   @   r   )ÚOffsetCommitResponse_v7r   é   N)r   r   r   r   r   r'   r   r   r   r   r   r)   <   r   r)   c                   @   s\   e Zd ZdZdZededƒfdededƒfdedefd	e	fd
edƒfƒfƒfƒZ
ddiZdS )ÚOffsetCommitRequest_v0r   r   Úgroup_idr   r   r   r   r   Úcommitted_offsetÚcommitted_metadataÚconsumer_groupN)r   r   r   r   r   r   r	   r   r   r   r   ÚALIASESr   r   r   r   r+   B   s     


ýþþ
ÿr+   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d
efde	fde	fdedƒfƒfƒfƒZ
ddddœZdS )ÚOffsetCommitRequest_v1r   r   r,   r   Úgeneration_id_or_member_epochÚ	member_idr   r   r   r   r-   Úcommit_timestampr.   ©r/   Úconsumer_group_generation_idÚconsumer_idN©r   r   r   r   r   r   r	   r   r   r   r   r0   r   r   r   r   r1   S   s*    



üþü
ýr1   c                   @   s|   e Zd ZdZdZededƒfdefdedƒfdefde	d	edƒfd
e	defdefdedƒfƒfƒfƒZ
dZdddddœZdS )ÚOffsetCommitRequest_v2r   r   r,   r   r2   r3   Úretention_time_msr   r   r   r   r-   r.   éÿÿÿÿ)r/   r6   r7   Úretention_timeN)r   r   r   r   r   r   r	   r   r   r   r   ÚDEFAULT_RETENTION_TIMEr0   r   r   r   r   r9   i   s.    



ýþû
ür9   c                   @   ó$   e Zd ZdZdZejZdZejZdS )ÚOffsetCommitRequest_v3r   r!   r;   N)	r   r   r   r   r   r9   r   r=   r0   r   r   r   r   r?      ó    
r?   c                   @   r>   )ÚOffsetCommitRequest_v4r   r$   r;   N)	r   r   r   r   r   r?   r   r=   r0   r   r   r   r   rA   ‰   r@   rA   c                   @   sp   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d
efde	fdedƒfƒfƒfƒZ
ddddœZdS )ÚOffsetCommitRequest_v5r   r&   r,   r   r2   r3   r   r   r   r   r-   r.   r5   Nr8   r   r   r   r   rB   ‘   s(    



ýþü
ýrB   c                   @   sp   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d
efde	fdefdedƒfƒfƒfƒZ
ejZdS )ÚOffsetCommitRequest_v6r   r(   r,   r   r2   r3   r   r   r   r   r-   Úcommitted_leader_epochr.   N)r   r   r   r   r   r   r	   r   r   r   r   rB   r0   r   r   r   r   rC   ¦   s$    



üþü
rC   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defde	fdefdedƒfƒfƒfƒZ
ddddœZdS )ÚOffsetCommitRequest_v7r   r*   r,   r   r2   r3   Úgroup_instance_idr   r   r   r   r-   rD   r.   )r/   Úgeneration_idr7   Nr8   r   r   r   r   rE   ¸   s,    




üþû
ýrE   c                   @   sP   e Zd ZdZdZedededƒfdedefde	fd	edƒfd
e
fƒfƒfƒZdS )ÚOffsetFetchResponse_v0é	   r   r   r   r   r   r   r-   Úmetadatar   N©r   r   r   r   r   r   r   r	   r   r   r   r   r   r   r   r   rH   Û   s    

üþÿrH   c                   @   r   )ÚOffsetFetchResponse_v1rI   r   N)r   r   r   r   r   rH   r   r   r   r   r   rL   é   r   rL   c                   @   sV   e Zd ZdZdZedededƒfdedefde	fd	edƒfd
e
fƒfƒfd
e
fƒZdS )ÚOffsetFetchResponse_v2rI   r   r   r   r   r   r   r-   rJ   r   NrK   r   r   r   r   rM   ï   s    

üþørM   c                   @   s\   e Zd ZdZdZedefdededƒfdedefd	e	fd
edƒfde
fƒfƒfde
fƒZdS )ÚOffsetFetchResponse_v3rI   r!   r"   r   r   r   r   r   r-   rJ   r   N©r   r   r   r   r   r   r   r   r	   r   r   r   r   r   r   r   rN   ÿ   s     

üþ÷rN   c                   @   r   )ÚOffsetFetchResponse_v4rI   r$   N)r   r   r   r   r   rN   r   r   r   r   r   rP     r   rP   c                   @   sb   e Zd ZdZdZedefdededƒfdedefd	e	fd
efdedƒfde
fƒfƒfde
fƒZdS )ÚOffsetFetchResponse_v5rI   r&   r"   r   r   r   r   r   r-   rD   rJ   r   NrO   r   r   r   r   rQ     s"    

ûþörQ   c                   @   sH   e Zd ZdZdZededƒfdededƒfdeeƒfƒfƒZ	ddiZ
d	S )
ÚOffsetFetchRequest_v0rI   r   r,   r   r   r   Úpartition_indexesr/   N)r   r   r   r   r   r   r	   r   r   r   r0   r   r   r   r   rR   &  s    


þþÿrR   c                   @   ó    e Zd ZdZdZejZejZdS )ÚOffsetFetchRequest_v1rI   r   N)r   r   r   r   r   rR   r   r0   r   r   r   r   rU   4  ó
    
rU   c                   @   rT   )ÚOffsetFetchRequest_v2rI   r   N)r   r   r   r   r   rU   r   r0   r   r   r   r   rW   ;  s
    
rW   c                   @   rT   )ÚOffsetFetchRequest_v3rI   r!   N)r   r   r   r   r   rW   r   r0   r   r   r   r   rX   E  rV   rX   c                   @   rT   )ÚOffsetFetchRequest_v4rI   r$   N)r   r   r   r   r   rX   r   r0   r   r   r   r   rY   L  rV   rY   c                   @   rT   )ÚOffsetFetchRequest_v5rI   r&   N)r   r   r   r   r   rY   r   r0   r   r   r   r   rZ   S  rV   rZ   N)*Úapir   r   Útypesr   r   r   r   r   r	   r
   r   r   r    r#   r%   r'   r)   r+   r1   r9   r?   rA   rB   rC   rE   ÚOffsetCommitRequestÚOffsetCommitResponserH   rL   rM   rN   rP   rQ   rR   rU   rW   rX   rY   rZ   ÚOffsetFetchRequestÚOffsetFetchResponser   r   r   r   Ú<module>   s\     ýý
ýý