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eeegZe
eegZdS )é   )ÚRequestÚResponse)ÚArrayÚInt16ÚInt32ÚInt64ÚSchemaÚStringc                
   @   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 )ÚTxnOffsetCommitResponse_v0é   é    Úthrottle_time_msÚtopicsÚnameúutf-8Ú
partitionsÚpartition_indexÚ
error_codeN)Ú__name__Ú
__module__Ú__qualname__ÚAPI_KEYÚAPI_VERSIONr   r   r   r	   r   ÚSCHEMA© r   r   úb/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/txn_offset_commit.pyr
      s    
þþþr
   c                   @   ó   e Zd ZdZdZejZdS )ÚTxnOffsetCommitResponse_v1r   r   N)r   r   r   r   r   r
   r   r   r   r   r   r      ó    
r   c                   @   r   )ÚTxnOffsetCommitResponse_v2r   é   N)r   r   r   r   r   r   r   r   r   r   r   r      r   r   c                   @   sj   e Zd ZdZdZededƒfdedƒfde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S )ÚTxnOffsetCommitRequest_v0r   r   Útransactional_idr   Úgroup_idÚproducer_idÚproducer_epochr   r   r   r   Úcommitted_offsetÚcommitted_metadataN©r   r   r   r   r   r   r	   r   r   r   r   r   r   r   r   r   r!      s"    



ýþûr!   c                   @   r   )ÚTxnOffsetCommitRequest_v1r   r   N)r   r   r   r   r   r!   r   r   r   r   r   r)   -   r   r)   c                   @   sp   e Zd ZdZdZededƒfdedƒfdefde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S )ÚTxnOffsetCommitRequest_v2r   r    r"   r   r#   r$   r%   r   r   r   r   r&   Úcommitted_leader_epochr'   Nr(   r   r   r   r   r*   3   s$    



üþûr*   N)Úapir   r   Útypesr   r   r   r   r   r	   r
   r   r   r!   r)   r*   ÚTxnOffsetCommitRequestÚTxnOffsetCommitResponser   r   r   r   Ú<module>   s     ÿÿ