
    Ii                        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   " 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$)%    )absolute_import)RequestResponse)ArrayBooleanInt16Int32SchemaStringc                       \ rS rSrSrSr\" S\" S\4S\	" S5      4S\45      4S	\" S
\
4S\	" S5      4S\" S
\
4S\4S\4S\" \5      4S\" \5      45      45      45      rSrg)MetadataResponse_v0      r   brokersnode_idhostutf-8porttopics
error_codetopic
partitions	partitionleaderreplicasisr N)__name__
__module____qualname____firstlineno__API_KEYAPI_VERSIONr
   r   r	   r   r   SCHEMA__static_attributes__r       =/venv/lib/python3.13/site-packages/kafka/protocol/metadata.pyr   r      s    GK	EVG_%UO 	 
55!fWo&5u%e$5!U5\*e%' () 	*Fr&   r   c                       \ rS rSrSrSr\" S\" S\4S\	" S5      4S\4S	\	" S5      45      4S
\4S\" S\
4S\	" S5      4S\4S\" S\
4S\4S\4S\" \5      4S\" \5      45      45      45      rSrg)MetadataResponse_v1   r      r   r   r   r   r   rackcontroller_idr   r   r   is_internalr   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)      s    GK	EVG_%UOVG_%	' 	(
 
% 	55!fWo&G$5u%e$5!U5\*e%' (		) 		*Fr&   r)   c                       \ rS rSrSrSr\" S\" S\4S\	" S5      4S\4S	\	" S5      45      4S
\	" S5      4S\4S\" S\
4S\	" S5      4S\4S\" S\
4S\4S\4S\" \5      4S\" \5      45      45      45      rSrg)MetadataResponse_v22   r      r   r   r   r   r   r,   
cluster_idr-   r   r   r   r.   r   r   r   r   r   r   Nr/   r   r&   r'   r1   r1   2   s    GK	EVG_%UOVG_%	' 	(
 
vg'	% 	55!fWo&G$5u%e$5!U5\*e%' (		) 		*Fr&   r1   c                       \ rS rSrSrSr\" S\4S\" S\4S\	" S5      4S\4S	\	" S5      45      4S
\	" S5      4S\4S\" S\
4S\	" S5      4S\4S\" S\
4S\4S\4S\" \5      4S\" \5      45      45      45      rSrg)MetadataResponse_v3J   r   throttle_time_msr   r   r   r   r   r,   r4   r-   r   r   r   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'   r6   r6   J   s    GK	U#	EVG_%UOVG_%	' 	(
 
vg'	% 	55!fWo&G$5u%e$5!U5\*e%' (		) 		*Fr&   r6   c                   4    \ rS rSrSrSr\R                  rSrg)MetadataResponse_v4c   r      r   N)	r   r   r    r!   r"   r#   r6   r$   r%   r   r&   r'   r;   r;   c   s    GK ''Fr&   r;   c                      \ rS rSrSrSr\" S\4S\" S\4S\	" S5      4S	\4S
\	" S5      45      4S\	" S5      4S\4S\" S\
4S\	" S5      4S\4S\" S\
4S\4S\4S\" \5      4S\" \5      4S\" \5      45      45      45      rSrg)MetadataResponse_v5i   r      r8   r   r   r   r   r   r,   r4   r-   r   r   r   r.   r   r   r   r   r   offline_replicasr   Nr9   r   r&   r'   r?   r?   i   s    GK	U#	EVG_%UOVG_%	' 	(
 
vg'	% 	55!fWo&G$5u%e$5!U5\*e%#U5\24 5	
6 
	7Fr&   r?   c                   8    \ rS rSrSrSrSr\R                  rSr	g)MetadataResponse_v6   zuMetadata Request/Response v6 is the same as v5,
but on quota violation, brokers send out responses before throttling.r      r   N)
r   r   r    r!   __doc__r"   r#   r?   r$   r%   r   r&   r'   rD   rD      s    MGK ''Fr&   rD   c                      \ rS rSrSrSrSr\" S\4S\	" S\4S\
" S	5      4S
\4S\
" S	5      45      4S\
" S	5      4S\4S\	" S\4S\
" S	5      4S\4S\	" S\4S\4S\4S\4S\	" \5      4S\	" \5      4S\	" \5      45      45      45      rSrg)MetadataResponse_v7   z(v7 adds per-partition leader_epoch fieldr   r   r8   r   r   r   r   r   r,   r4   r-   r   r   r   r.   r   r   r   leader_epochr   r   rB   r   N)r   r   r    r!   rG   r"   r#   r
   r	   r   r   r   r   r$   r%   r   r&   r'   rI   rI      s    2GK	U#	EVG_%UOVG_%	' 	(
 
vg'	% 	55!fWo&G$5u%e$5!'U5\*e%#U5\24 5	6 	7Fr&   rI   c                   T    \ rS rSrSrSr\r\" S\	" \
" S5      5      45      r/ r/ rSrg)MetadataRequest_v0   r   r   r   r   r   N)r   r   r    r!   r"   r#   r   RESPONSE_TYPEr
   r   r   r$   
ALL_TOPICS	NO_TOPICSr%   r   r&   r'   rM   rM      s8    GK'M	5)*F JIr&   rM   c                   @    \ rS rSrSrSr\r\R                  r	Sr
/ rSrg)MetadataRequest_v1   r   r+   Nr   )r   r   r    r!   r"   r#   r)   rO   rM   r$   rP   rQ   r%   r   r&   r'   rS   rS      &    GK'M&&FJIr&   rS   c                   @    \ rS rSrSrSr\r\R                  r	Sr
/ rSrg)MetadataRequest_v2   r   r3   Nr   )r   r   r    r!   r"   r#   r1   rO   rS   r$   rP   rQ   r%   r   r&   r'   rW   rW      rU   r&   rW   c                   @    \ rS rSrSrSr\r\R                  r	Sr
/ rSrg)MetadataRequest_v3   r   Nr   )r   r   r    r!   r"   r#   r6   rO   rS   r$   rP   rQ   r%   r   r&   r'   rZ   rZ      rU   r&   rZ   c                   Z    \ rS rSrSrSr\r\" S\	" \
" S5      5      4S\45      rSr/ rSrg)	MetadataRequest_v4   r   r=   r   r   allow_auto_topic_creationNr   )r   r   r    r!   r"   r#   r;   rO   r
   r   r   r   r$   rP   rQ   r%   r   r&   r'   r]   r]      s@    GK'M	5)*	$g.F JIr&   r]   c                   D    \ rS rSrSrSrSr\r\	R                  r
Sr/ rSrg)MetadataRequest_v5   z
The v5 metadata request is the same as v4.
An additional field for offline_replicas has been added to the v5 metadata response
r   rA   Nr   )r   r   r    r!   rG   r"   r#   r?   rO   r]   r$   rP   rQ   r%   r   r&   r'   ra   ra      s-     GK'M&&FJIr&   ra   c                   @    \ rS rSrSrSr\r\R                  r	Sr
/ rSrg)MetadataRequest_v6   r   rF   Nr   )r   r   r    r!   r"   r#   rD   rO   ra   r$   rP   rQ   r%   r   r&   r'   rd   rd      rU   r&   rd   c                   @    \ rS rSrSrSr\r\R                  r	Sr
/ rSrg)MetadataRequest_v7   r   r   Nr   )r   r   r    r!   r"   r#   rI   rO   rd   r$   rP   rQ   r%   r   r&   r'   rg   rg      rU   r&   rg   N)
__future__r   kafka.protocol.apir   r   kafka.protocol.typesr   r   r   r	   r
   r   r   r)   r1   r6   r;   r?   rD   rI   rM   rS   rW   rZ   r]   ra   rd   rg   MetadataRequestMetadataResponser   r&   r'   <module>rn      s   & 0 M M( (( .( 0( 2(( (( 4(( (( 8    	 	
 
   *,>*,>* ,.A,.A, r&   