
    9h	              	          S SK JrJr  S SKJrJrJrJrJrJ	r	J
r
   " S S\5      r " S S\5      r " S S\5      r " S	 S
\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S\5      r " S S \5      r " S! S"\5      r " S# S$\5      r " S% S&\5      r " S' S(\5      r\\\\\\\\\/	r\\\\\\\\\/	rg))*   )RequestResponse)ArrayBytesInt16Int32Int64SchemaStringc                   n    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S\
4S	\45      45      45      rS
rg)ProduceResponse_v0       topicstopicutf-8
partitions	partition
error_codeoffset N__name__
__module____qualname____firstlineno__API_KEYAPI_VERSIONr
   r   r   r   r   r	   SCHEMA__static_attributes__r       ^C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/protocol/produce.pyr   r      sY    GK&/* $e,|U.ChPUEV	
Fr!   r   c                   t    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\45      45      4S\	45      rSrg)ProduceResponse_v1   r   r   r   r   r   r   r   r   r   throttle_time_msr   Nr   r   r!   r"   r$   r$      sc    GK&/* $e,|U.ChPUEV	
 
U#Fr!   r$   c                   z    \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\4S\45      45      4S\	45      rSrg)ProduceResponse_v2,   r      r   r   r   r   r   r   r   	timestampr&   r   Nr   r   r!   r"   r(   r(   ,   sl    GK&/* $e,%u-!5)$e,		
 
U#!Fr!   r(   c                   4    \ rS rSrSrSr\R                  rSrg)ProduceResponse_v3C   r      r   N)	r   r   r   r   r   r   r(   r   r    r   r!   r"   r-   r-   C   s    GK&&Fr!   r-   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v4I   
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      r   N)
r   r   r   r   __doc__r   r   r-   r   r    r   r!   r"   r1   r1   I   s     GK&&Fr!   r1   c                       \ rS rSrSrSr\" S\" S\" S5      4S\" S\	4S	\
4S
\4S\4S\45      45      4S\	45      rSrg)ProduceResponse_v5U   r   r   r   r   r   r   r   r   r   r+   log_start_offsetr&   r   Nr   r   r!   r"   r7   r7   U   st    GK&/* $e,%u-!5)$e,+U3		
  
U##Fr!   r7   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v6m   p
The version number is bumped to indicate that on quota violation brokers send out
responses before throttling.
r      r   N)
r   r   r   r   r5   r   r   r7   r   r    r   r!   r"   r;   r;   m   s    
 GK&&Fr!   r;   c                   8    \ rS rSrSrSrSr\R                  rSr	g)ProduceResponse_v7x   >
V7 bumped up to indicate ZStandard capability. (see KIP-110)
r      r   N)
r   r   r   r   r5   r   r   r;   r   r    r   r!   r"   r@   r@   x   s     GK&&Fr!   r@   c                       \ rS rSrSrSrSr\" S\" S\	" S5      4S\" S	\
4S
\4S\4S\4S\4S\" S\
4S\	" S5      45      4S\	" S5      45      45      4S\
45      rSrg)ProduceResponse_v8   z^
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+   r9   record_errorsbatch_indexbatch_index_error_messageerror_messager&   r   N)r   r   r   r   r5   r   r   r
   r   r   r   r   r	   r   r    r   r!   r"   rE   rE      s    
 GK&/* $e,%u-!5)$e,+U3+!!. 6!<fWo N )&/:	
0 
U#3Fr!   rE   c                   2    \ rS rSr% Sr\\S'   S\4S jrSr	g)ProduceRequestBase   r   required_acksreturnc                      U R                   S:g  $ )Nr   )rO   )selfs    r"   expect_response"ProduceRequestBase.expect_response   s    !!Q&&r!   r   N)
r   r   r   r   r   int__annotations__boolrS   r    r   r!   r"   rM   rM      s    G' 'r!   rM   c                   t    \ rS rSrSr\r\" S\4S\	4S\
" S\" S5      4S\
" S	\	4S
\45      45      45      rSrg)ProduceRequest_v0   r   rO   timeoutr   r   r   r   r   messagesr   N)r   r   r   r   r   r   RESPONSE_TYPEr
   r   r   r   r   r   r   r    r   r!   r"   rY   rY      s[    K&M	% 	E&/*uk5%9J;NOP	

Fr!   rY   c                   4    \ rS rSrSr\r\R                  rSr	g)ProduceRequest_v1   r   r   N)
r   r   r   r   r   r$   r]   rY   r   r    r   r!   r"   r_   r_          K&M%%Fr!   r_   c                   4    \ rS rSrSr\r\R                  rSr	g)ProduceRequest_v2   r*   r   N)
r   r   r   r   r   r(   r]   r_   r   r    r   r!   r"   rc   rc      ra   r!   rc   c                       \ rS rSrSr\r\" S\" S5      4S\	4S\
4S\" S\" S5      4S	\" S
\
4S\45      45      45      rSrg)ProduceRequest_v3   r/   transactional_idr   rO   r[   r   r   r   r   r\   r   N)r   r   r   r   r   r-   r]   r
   r   r   r   r   r   r   r    r   r!   r"   rf   rf      sg    K&M	VG_-	% 	E&/*uk5%9J;NOP	
	Fr!   rf   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v4   r3   r4   r   N)r   r   r   r   r5   r   r1   r]   rf   r   r    r   r!   r"   rj   rj      s     K&M%%Fr!   rj   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v5   z
Same as v4. The version number is bumped since the v5 response includes an
additional partition level field: the log_start_offset.
r   r   N)r   r   r   r   r5   r   r7   r]   rj   r   r    r   r!   r"   rm   rm          
 K&M%%Fr!   rm   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v6   r=   r>   r   N)r   r   r   r   r5   r   r;   r]   rm   r   r    r   r!   r"   rq   rq      ro   r!   rq   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v7   rB   rC   r   N)r   r   r   r   r5   r   r@   r]   rq   r   r    r   r!   r"   rt   rt      s     K&M%%Fr!   rt   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)ProduceRequest_v8i	  zs
V8 bumped up to add two new fields record_errors offset list and error_message to
PartitionResponse (See KIP-467)
rG   r   N)r   r   r   r   r5   r   rE   r]   rt   r   r    r   r!   r"   rw   rw   	  ro   r!   rw   N) apir   r   typesr   r   r   r   r	   r
   r   r   r$   r(   r-   r1   r7   r;   r@   rE   rM   rY   r_   rc   rf   rj   rm   rq   rt   rw   ProduceRequestProduceResponser   r!   r"   <module>r|      sG   " D D D & ( .' '	' 	' 0' '' '" "J' '*  &* &&* &* "	&* 	&&* &&* &&* &&* & 
 
r!   