o
    `šj½  ã                   @   s€   d dl mZmZ d dl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eegZe	e
gZdS )é   )ÚRequestÚResponse)ÚInt16ÚInt32ÚInt64ÚSchemaÚStringc                   @   s2   e Zd ZdZdZedefdefdefdefƒZ	dS )ÚInitProducerIdResponse_v0é   é    Úthrottle_time_msÚ
error_codeÚproducer_idÚproducer_epochN)
Ú__name__Ú
__module__Ú__qualname__ÚAPI_KEYÚAPI_VERSIONr   r   r   r   ÚSCHEMA© r   r   úa/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/init_producer_id.pyr	      s    ür	   c                   @   ó   e Zd ZdZdZejZdS )ÚInitProducerIdResponse_v1r
   r   N)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fƒZdS )ÚInitProducerIdRequest_v0r
   r   Útransactional_idzutf-8Útransaction_timeout_msN)	r   r   r   r   r   r   r   r   r   r   r   r   r   r      s    
þr   c                   @   r   )ÚInitProducerIdRequest_v1r
   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   ÚInitProducerIdRequestÚInitProducerIdResponser   r   r   r   Ú<module>   s    	ÿÿ