o
    `šjW  ã                   @   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)ÚBooleanÚInt16ÚInt32ÚInt64ÚSchemaÚStringc                   @   s&   e Zd ZdZdZedefdefƒZdS )ÚEndTxnResponse_v0é   é    Úthrottle_time_msÚ
error_codeN)	Ú__name__Ú
__module__Ú__qualname__ÚAPI_KEYÚAPI_VERSIONr   r   r   ÚSCHEMA© r   r   úX/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/end_txn.pyr
      s    þr
   c                   @   ó   e Zd ZdZdZejZdS )ÚEndTxnResponse_v1r   r   N)r   r   r   r   r   r
   r   r   r   r   r   r      ó    
r   c                   @   r   )ÚEndTxnResponse_v2r   é   N)r   r   r   r   r   r   r   r   r   r   r   r      r   r   c                   @   s6   e Zd ZdZdZededƒfdefdefde	fƒZ
dS )	ÚEndTxnRequest_v0r   r   Útransactional_idzutf-8Úproducer_idÚproducer_epochÚ	committedN)r   r   r   r   r   r   r	   r   r   r   r   r   r   r   r   r      s    
ür   c                   @   r   )ÚEndTxnRequest_v1r   r   N)r   r   r   r   r   r   r   r   r   r   r   r!   $   r   r!   c                   @   r   )ÚEndTxnRequest_v2r   r   N)r   r   r   r   r   r!   r   r   r   r   r   r"   *   r   r"   N)Úapir   r   Útypesr   r   r   r   r   r	   r
   r   r   r   r!   r"   ÚEndTxnRequestÚEndTxnResponser   r   r   r   Ú<module>   s     	
ÿÿ