
    9h
7                        S SK Jr  SSKJrJr  SSKJr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  " S+ S,\5      r! " S- S.\5      r" " S/ S0\5      r# " S1 S2\5      r$ " S3 S4\5      r%\\\\\\\ \!\"\#\$\%/r&\\\\\\\\\\\\/r'g5)6    )Optional   )RequestResponse)ArrayBytesInt8Int16Int32Int64SchemaStringc                       \ 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5      r\\\\\\\\\\4      4         \S'   Srg)FetchResponse_v0   r   r   topicsutf-8
partitions	partition
error_codehighwater_offsetmessage_set N)__name__
__module____qualname____firstlineno__API_KEYAPI_VERSIONr   r   r   r   r
   r   r   SCHEMAr   listtuplestrintbytes__annotations____static_attributes__r       \C:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/protocol/fetch.pyr   r      s    GK6'?+ $e,%u-+U3&.		
F$ T%T%S#u0D*E%F FGHIIr(   r   c                   z    \ rS rSrSrSr\" S\4S\" S\	" S5      4S\" S\4S\
4S	\4S
\45      45      45      rSrg)FetchResponse_v1   r   throttle_time_msr   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)   r+   r+      sj    GK	U#6'?+ $e,%u-+U3&.		
Fr(   r+   c                   4    \ rS rSrSrSr\R                  rSrg)FetchResponse_v26   r      r   N)	r   r   r   r   r   r   r+   r    r'   r   r(   r)   r0   r0   6       GK$$Fr(   r0   c                   4    \ rS rSrSrSr\R                  rSrg)FetchResponse_v3<   r      r   N)	r   r   r   r   r   r   r0   r    r'   r   r(   r)   r5   r5   <   r3   r(   r5   c                       \ rS rSrSrSr\" S\4S\" S\	" S5      4S\" S\4S	\
4S
\4S\4S\" S\4S\45      4S\45      45      45      rSrg)FetchResponse_v4B   r      r-   r   r   r   r   r   r   last_stable_offsetaborted_transactionsproducer_idfirst_offsetr   r   Nr.   r   r(   r)   r9   r9   B   s    GK	U#6'?+ $e,%u-+U3-u52!=%"8>5:QR '.
	
Fr(   r9   c                       \ rS rSrSrSr\" S\4S\" S\	" S5      4S\" S\4S	\
4S
\4S\4S\4S\" S\4S\45      4S\45      45      45      rSrg)FetchResponse_v5^   r      r-   r   r   r   r   r   r   r<   log_start_offsetr=   r>   r?   r   r   Nr.   r   r(   r)   rA   rA   ^   s    GK	U#6'?+ $e,%u-+U3-u5+U32!=%"8>5:QR '.	
Fr(   rA   c                   8    \ rS rSrSrSrSr\R                  rSr	g)FetchResponse_v6{   z
Same as FetchResponse_v5. 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 <= 5
r      r   N)
r   r   r   r   __doc__r   r   rA   r    r'   r   r(   r)   rF   rF   {   s     GK$$Fr(   rF   c                       \ rS rSrSrSrSr\" S\4S\	4S\4S\
" S\" S	5      4S
\
" S\4S\	4S\4S\4S\4S\
" S\4S\45      4S\45      45      45      rSrg)FetchResponse_v7   z+
Add error_code and session_id to response
r   r   r-   r   
session_idr   r   r   r   r   r<   rD   r=   r>   r?   r   r   N)r   r   r   r   rI   r   r   r   r   r
   r   r   r   r   r    r'   r   r(   r)   rK   rK      s     GK	U#	u	u6'?+ $e,%u-+U3-u5+U32!=%"8>5:QR '.	
	Fr(   rK   c                   4    \ rS rSrSrSr\R                  rSrg)FetchResponse_v8   r      r   N	r   r   r   r   r   r   rK   r    r'   r   r(   r)   rO   rO      r3   r(   rO   c                   4    \ rS rSrSrSr\R                  rSrg)FetchResponse_v9   r   	   r   NrR   r   r(   r)   rT   rT      r3   r(   rT   c                   4    \ rS rSrSrSr\R                  rSrg)FetchResponse_v10   r   
   r   NrR   r   r(   r)   rX   rX      s    GK$$Fr(   rX   c                       \ rS rSrSrSr\" S\4S\4S\4S\	" S\
" S5      4S	\	" S
\4S\4S\4S\4S\4S\	" S\4S\45      4S\4S\45      45      45      rSrg)FetchResponse_v11   r      r-   r   rM   r   r   r   r   r   r<   rD   r=   r>   r?   preferred_read_replicar   r   N)r   r   r   r   r   r   r   r   r
   r   r   r   r   r    r'   r   r(   r)   r\   r\      s    GK	U#	u	u6'?+ $e,%u-+U3-u5+U32!=%"8>5:QR 259&.	
	Fr(   r\   c                       \ rS rSr% SrSr\r\" S\	4S\	4S\	4S\
" S\" S	5      4S
\
" S\	4S\4S\	45      45      45      r\\   \S'   Srg)FetchRequest_v0   r   r   
replica_idmax_wait_time	min_bytesr   topicr   r   r   offset	max_bytesr   N)r   r   r   r   r   r   r   RESPONSE_TYPEr   r   r   r   r   r    r   r$   r&   r'   r   r(   r)   ra   ra      s    GK$M	u	% 	e&/* $e,x.?+uAU	
	F$ }r(   ra   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)FetchRequest_v1   r   r   N)r   r   r   r   r   r   r+   ri   ra   r    r'   r   r(   r)   rk   rk          GK$M##Fr(   rk   c                   8    \ rS rSrSrSr\r\R                  r	Sr
g)FetchRequest_v2   r   r2   r   N)r   r   r   r   r   r   r0   ri   rk   r    r'   r   r(   r)   ro   ro      rm   r(   ro   c                       \ rS rSrSrSr\r\" S\	4S\	4S\	4S\	4S\
" S	\" S
5      4S\
" S\	4S\4S\	45      45      45      rSrg)FetchRequest_v3i  r   r7   rc   rd   re   rh   r   rf   r   r   r   rg   r   N)r   r   r   r   r   r   r5   ri   r   r   r   r   r   r    r'   r   r(   r)   rr   rr     s}    GK$M	u	% 	e	e&/* $e,x.?+uAU	
Fr(   rr   c                       \ rS rSrSrSr\r\" S\	4S\	4S\	4S\	4S\
4S	\" S
\" S5      4S\" S\	4S\4S\	45      45      45      rSrg)FetchRequest_v4i  r   r;   rc   rd   re   rh   isolation_levelr   rf   r   r   r   rg   r   N)r   r   r   r   r   r   r9   ri   r   r   r	   r   r   r   r    r'   r   r(   r)   rt   rt     s    GK$M	u	% 	e	e	D!&/* $e,x.?+uAU	
Fr(   rt   c                       \ rS rSrSrSr\r\" S\	4S\	4S\	4S\	4S\
4S	\" S
\" S5      4S\" S\	4S\4S\4S\	45      45      45      rSrg)FetchRequest_v5i5  r   rC   rc   rd   re   rh   ru   r   rf   r   r   r   fetch_offsetrD   r   N)r   r   r   r   r   r   rA   ri   r   r   r	   r   r   r   r    r'   r   r(   r)   rw   rw   5  s    GK$M	u	% 	e	e	D!&/* $e,'/+U3$e,		
Fr(   rw   c                   <    \ rS rSrSrSrSr\r\	R                  r
Srg)FetchRequest_v6iR  a
  
The body of FETCH_REQUEST_V6 is the same as FETCH_REQUEST_V5. 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 <= 5
r   rH   r   N)r   r   r   r   rI   r   r   rF   ri   rw   r    r'   r   r(   r)   rz   rz   R  s#     GK$M##Fr(   rz   c                       \ rS rSrSrSrSr\r\	" S\
4S\
4S\
4S\
4S	\4S
\
4S\
4S\" S\" S5      4S\" S\
4S\4S\4S\
45      45      4S\" S\" S5      4S\" \
5      45      45	      rSrg)FetchRequest_v7i`  z 
Add incremental fetch requests
r   r   rc   rd   re   rh   ru   rM   session_epochr   rf   r   r   r   rx   rD   forgotten_topics_datar   N)r   r   r   r   rI   r   r   rK   ri   r   r   r	   r   r   r   r    r'   r   r(   r)   r|   r|   `  s     GK$M	u	% 	e	e	D!	u	% &/* $e,'/+U3$e,		
  $7F7O,|U5\.JK	
/Fr(   r|   c                   <    \ rS rSrSrSrSr\r\	R                  r
Srg)FetchRequest_v8i  z]
bump used to indicate that on quota violation brokers send out responses before
throttling.
r   rQ   r   N)r   r   r   r   rI   r   r   rO   ri   r|   r    r'   r   r(   r)   r   r     s#    
 GK$M##Fr(   r   c                       \ rS rSrSrSrSr\r\	" S\
4S\
4S\
4S\
4S	\4S
\
4S\
4S\" S\" S5      4S\" S\
4S\
4S\4S\4S\
45      45      4S\" S\" S5      4S\" \
5      45      45	      rSrg)FetchRequest_v9i  z-
adds the current leader epoch (see KIP-320)
r   rV   rc   rd   re   rh   ru   rM   r}   r   rf   r   r   r   current_leader_epochrx   rD   r~   r   N)r   r   r   r   rI   r   r   rT   ri   r   r   r	   r   r   r   r    r'   r   r(   r)   r   r     s     GK$M	u	% 	e	e	D!	u	% &/* $e,/7'/+U3$e,		
" $&/*uU|,	
1Fr(   r   c                   <    \ rS rSrSrSrSr\r\	R                  r
Srg)FetchRequest_v10i  z;
bumped up to indicate ZStandard capability. (see KIP-110)
r   rZ   r   N)r   r   r   r   rI   r   r   rX   ri   r   r    r'   r   r(   r)   r   r     s#     GK%M##Fr(   r   c                       \ rS rSrSrSrSr\r\	" S\
4S\
4S\
4S\
4S	\4S
\
4S\
4S\" S\" S5      4S\" S\
4S\
4S\4S\4S\
45      45      4S\" S\" S5      4S\" \
5      45      4S\" S5      45
      rSrg)FetchRequest_v11i  z8
added rack ID to support read from followers (KIP-392)
r   r^   rc   rd   re   rh   ru   rM   r}   r   rf   r   r   r   r   rx   rD   r~   rack_idr   N)r   r   r   r   rI   r   r   r\   ri   r   r   r	   r   r   r   r    r'   r   r(   r)   r   r     s     GK%M	u	% 	e	e	D!	u	% &/* $e,/7'/+U3$e,		
" $7F7O,|U5\.JK	
 
F7O$9Fr(   r   N)(typingr   apir   r   typesr   r   r	   r
   r   r   r   r   r   r+   r0   r5   r9   rA   rF   rK   rO   rT   rX   r\   ra   rk   ro   rr   rt   rw   rz   r|   r   r   r   r   FetchRequestFetchResponser   r(   r)   <module>r      s    " J J JJx J0x .%x %%x %x 8x :	%x 	% x  F%x %%x %% % @g 2$g $$g $g 0g 4g :$g $#g #L	$g 	$'g 'T$w $%w %R  r(   