o
    `jX!                  	   @   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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)ArrayBooleanInt16Int32SchemaStringBitFieldc                   @   s~   e Zd ZdZdZededefdedfdeffded	e	fd
edfded	e	fdefdefdeefdeefffZ
dS )MetadataResponse_v0       brokersnode_idhostutf-8porttopics
error_codename
partitionspartition_index	leader_idreplica_nodes	isr_nodesN)__name__
__module____qualname__API_KEYAPI_VERSIONr   r   r   r	   r   SCHEMA r!   r!   Y/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/old/metadata.pyr      s*    



r   c                   @   s   e Zd ZdZdZededefdedfdefdedffd	efd
ede	fdedfde
fdede	fdefdefdeefdeefffZdS )MetadataResponse_v1r   r   r   r   r   r   r   rackcontroller_idr   r   r   is_internalr   r   r   r   r   Nr   r   r   r   r   r   r   r   r	   r   r   r    r!   r!   r!   r"   r#      s0    




r#   c                   @   s   e Zd ZdZdZededefdedfdefdedffd	edfd
efdede	fdedfde
fdede	fdefdefdeefdeefffZdS )MetadataResponse_v2r      r   r   r   r   r   r$   
cluster_idr%   r   r   r   r&   r   r   r   r   r   Nr'   r!   r!   r!   r"   r(   0   s2    





r(   c                   @   s   e Zd ZdZdZedefdedefdedfdefdedffd	edfd
efdede	fdedfde
fdede	fdefdefdeefdeefffZdS )MetadataResponse_v3r   throttle_time_msr   r   r   r   r   r$   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+   H   s4    





r+   c                   @   s   e Zd ZdZdZejZdS )MetadataResponse_v4r      N)r   r   r   r   r   r+   r    r!   r!   r!   r"   r.   a   s    
r.   c                   @   s   e Zd ZdZdZedefdedefdedfdefd	edffd
edfdefdede	fdedfde
fdede	fdefdefdeefdeefdeefffZdS )MetadataResponse_v5r      r,   r   r   r   r   r   r$   r*   r%   r   r   r   r&   r   r   r   r   r   offline_replicasNr-   r!   r!   r!   r"   r0   g   s6    






r0   c                   @   s   e Zd ZdZdZdZejZdS )MetadataResponse_v6zyMetadata Request/Response v6 is the same as v5,
    but on quota violation, brokers send out responses before throttling.r      N)r   r   r   __doc__r   r   r0   r    r!   r!   r!   r"   r3      s
    
r3   c                   @   s   e Zd ZdZdZdZedefdedefde	dfd	efd
e	dffde	dfdefdede
fde	dfdefdede
fdefdefdefdeefdeefdeefffZdS )MetadataResponse_v7z(v7 adds per-partition leader_epoch fieldr      r,   r   r   r   r   r   r$   r*   r%   r   r   r   r&   r   r   r   leader_epochr   r   r2   N)r   r   r   r5   r   r   r   r   r   r	   r   r   r    r!   r!   r!   r"   r6      s:    






r6   c                   @   s   e Zd ZdZdZdZedefdedefde	dfd	efd
e	dffde	dfdefdede
fde	dfdefdede
fdefdefdefdeefdeefdeeffdeffdefZdS )MetadataResponse_v8z$v8 adds authorized_operations fieldsr      r,   r   r   r   r   r   r$   r*   r%   r   r   r   r&   r   r   r   r8   r   r   r2   authorized_operationsN)r   r   r   r5   r   r   r   r   r   r	   r   r   r
   r    r!   r!   r!   r"   r9      s>    






r9   c                   @   s0   e Zd ZdZdZedeedfZg Z	g Z
dS )MetadataRequest_v0r   r   r   r   N)r   r   r   r   r   r   r   r	   r    
ALL_TOPICS	NO_TOPICSr!   r!   r!   r"   r<      s    r<   c                   @   "   e Zd ZdZdZejZdZg ZdS )MetadataRequest_v1r   r   N)	r   r   r   r   r   r<   r    r=   r>   r!   r!   r!   r"   r@          r@   c                   @   r?   )MetadataRequest_v2r   r)   N	r   r   r   r   r   r@   r    r=   r>   r!   r!   r!   r"   rB      rA   rB   c                   @   s"   e Zd ZdZdZejZdZg ZdS )MetadataRequest_v3r   NrC   r!   r!   r!   r"   rD      rA   rD   c                   @   s6   e Zd ZdZdZedeedfdefZ	dZ
g ZdS )MetadataRequest_v4r   r/   r   r   allow_auto_topic_creationNr   r   r   r   r   r   r   r	   r   r    r=   r>   r!   r!   r!   r"   rE      s    rE   c                   @   s&   e Zd ZdZdZdZejZdZg Z	dS )MetadataRequest_v5z
    The v5 metadata request is the same as v4.
    An additional field for offline_replicas has been added to the v5 metadata response
    r   r1   N)
r   r   r   r5   r   r   rE   r    r=   r>   r!   r!   r!   r"   rH      s    rH   c                   @   r?   )MetadataRequest_v6r   r4   N)	r   r   r   r   r   rH   r    r=   r>   r!   r!   r!   r"   rI      rA   rI   c                   @   r?   )MetadataRequest_v7r   r7   N)	r   r   r   r   r   rI   r    r=   r>   r!   r!   r!   r"   rJ     rA   rJ   c                   @   sB   e Zd ZdZdZedeedfdefdefdefZ	dZ
g ZdS )	MetadataRequest_v8r   r:   r   r   rF   %include_cluster_authorized_operations#include_topic_authorized_operationsNrG   r!   r!   r!   r"   rK     s    rK   N)apir   r   typesr   r   r   r   r   r	   r
   r   r#   r(   r+   r.   r0   r3   r6   r9   r<   r@   rB   rD   rE   rH   rI   rJ   rK   MetadataRequestMetadataResponser!   r!   r!   r"   <module>   s8    $
