o
    `šjf  ã                	   @   s”  d dl mZmZ d dlmZ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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eg	Zeeeeeeeeeg	Zd)S )*é   )ÚRequestÚResponse)ÚInt16ÚInt32ÚInt64ÚStringÚArrayÚSchemaÚBytesc                
   @   sN   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
fƒfƒfƒZd	diZd
S )ÚProduceResponse_v0é    Ú	responsesÚnameúutf-8Úpartition_responsesÚindexÚ
error_codeÚbase_offsetÚtopicsN)Ú__name__Ú
__module__Ú__qualname__ÚAPI_KEYÚAPI_VERSIONr	   r   r   r   r   r   ÚSCHEMAÚALIASES© r   r   úX/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/produce.pyr      s    
ýþÿ	ÿr   c                
   @   sR   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
fƒfƒfd
efƒZejZdS )ÚProduceResponse_v1r   r   r   r   r   r   r   r   r   Úthrottle_time_msN)r   r   r   r   r   r	   r   r   r   r   r   r   r   r   r   r   r   r   r      s    
ýþù
	r   c                   @   sX   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
fd
e
fƒfƒfdefƒZejZdS )ÚProduceResponse_v2r   é   r   r   r   r   r   r   r   Úlog_append_time_msr   N)r   r   r   r   r   r	   r   r   r   r   r   r   r   r   r   r   r   r   r    $   s     
üþø

r    c                   @   ó    e Zd ZdZdZejZejZdS )ÚProduceResponse_v3r   é   N)r   r   r   r   r   r    r   r   r   r   r   r   r$   4   s
    
r$   c                   @   ó$   e Zd ZdZdZdZejZejZdS )ÚProduceResponse_v4úØ
    The version number is bumped up to indicate that the client supports KafkaStorageException.
    The KafkaStorageException will be translated to NotLeaderForPartitionException in the response if version <= 3
    r   é   N)	r   r   r   Ú__doc__r   r   r$   r   r   r   r   r   r   r'   <   s    
r'   c                   @   s^   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
fd
e
fde
fƒfƒfdefƒZejZdS )ÚProduceResponse_v5r   é   r   r   r   r   r   r   r   r"   Úlog_start_offsetr   N)r   r   r   r   r   r	   r   r   r   r   r   r   r'   r   r   r   r   r   r+   G   s"    
ûþ÷
r+   c                   @   r&   )ÚProduceResponse_v6úx
    The version number is bumped to indicate that on quota violation brokers send out responses before throttling.
    r   é   N)	r   r   r   r*   r   r   r+   r   r   r   r   r   r   r.   X   ó    
r.   c                   @   r&   )ÚProduceResponse_v7úF
    V7 bumped up to indicate ZStandard capability. (see KIP-110)
    r   é   N)	r   r   r   r*   r   r   r.   r   r   r   r   r   r   r2   b   r1   r2   c                   @   s„   e Zd ZdZdZdZedededƒfdede	fd	e
fd
efdefdefdede	fdedƒfƒfdedƒfƒfƒfde	fƒZejZdS )ÚProduceResponse_v8zj
    V8 bumped up to add two new fields record_errors offset list and error_message
    (See KIP-467)
    r   é   r   r   r   r   r   r   r   r"   r-   Úrecord_errorsÚbatch_indexÚbatch_index_error_messageÚerror_messager   N)r   r   r   r*   r   r   r	   r   r   r   r   r   r   r2   r   r   r   r   r   r5   l   s.    

þ
öþñ
r5   c                   @   s   e Zd ZdZdd„ ZdS )ÚProduceRequestr   c                 C   s   | j dkrdS dS )Nr   FT)Úacks)Úselfr   r   r   Úexpect_responseŠ   s   
zProduceRequest.expect_responseN)r   r   r   r   r>   r   r   r   r   r;   ‡   s    r;   c                   @   sT   e Zd ZdZedefdefdededƒfdedefd	e	fƒfƒfƒZ
dddd
œZdS )ÚProduceRequest_v0r   r<   Ú
timeout_msÚ
topic_datar   r   Úpartition_datar   Úrecords)Úrequired_acksÚtimeoutr   N)r   r   r   r   r	   r   r   r   r   r
   r   r   r   r   r   r   r?      s"    
þþý

ýr?   c                   @   ó   e Zd ZdZejZejZdS )ÚProduceRequest_v1r   N)r   r   r   r   r?   r   r   r   r   r   r   rG   ¢   ó    
rG   c                   @   rF   )ÚProduceRequest_v2r!   N)r   r   r   r   rG   r   r   r   r   r   r   rI   ¨   rH   rI   c                   @   sX   e Zd ZdZededƒfdefdefdededƒfded	efd
e	fƒfƒfƒZ
ejZdS )ÚProduceRequest_v3r%   Útransactional_idr   r<   r@   rA   r   rB   r   rC   N)r   r   r   r   r	   r   r   r   r   r
   r   rI   r   r   r   r   r   rJ   ®   s    

þþü

rJ   c                   @   r#   )ÚProduceRequest_v4r(   r)   N)r   r   r   r*   r   rJ   r   r   r   r   r   r   rL   ¾   ó
    
rL   c                   @   r#   )ÚProduceRequest_v5z
    Same as v4. The version number is bumped since the v5 response includes an additional
    partition level field: the log_start_offset.
    r,   N)r   r   r   r*   r   rL   r   r   r   r   r   r   rN   È   rM   rN   c                   @   r#   )ÚProduceRequest_v6r/   r0   N)r   r   r   r*   r   rN   r   r   r   r   r   r   rO   Ò   ó
    
rO   c                   @   r#   )ÚProduceRequest_v7r3   r4   N)r   r   r   r*   r   rO   r   r   r   r   r   r   rQ   Û   rP   rQ   c                   @   r#   )ÚProduceRequest_v8z
    V8 bumped up to add two new fields record_errors offset list and error_message to PartitionResponse
    (See KIP-467)
    r6   N)r   r   r   r*   r   rQ   r   r   r   r   r   r   rR   ä   rM   rR   N)Úapir   r   Útypesr   r   r   r   r   r	   r
   r   r   r    r$   r'   r+   r.   r2   r5   r;   r?   rG   rI   rJ   rL   rN   rO   rQ   rR   ÚProduceResponser   r   r   r   Ú<module>   s:    $

	

		ýý