o
    `j                     @  sP   d dl mZ ddlmZ d dlmZ G dd deZG dd deZddgZd	S )
    )annotations   )
ApiMessage)classpropertyc                      s&   e Zd ZdZg Zd fdd	Z  ZS )MetadataRequestNFc                   s4   |dks	| j dkr| jd u rg | _t j|||dS )Nr   )versionheaderframed)API_VERSIONtopicssuperencode)selfr   r   r	   	__class__ ^/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/metadata/metadata.pyr      s   
zMetadataRequest.encode)NFF)__name__
__module____qualname__
ALL_TOPICS	NO_TOPICSr   __classcell__r   r   r   r   r      s    r   c                   @  s   e Zd Zedd ZdS )MetadataResponsec                 C  sT   d|d d d< d|d d d< d|d d d d d< d|d d d d d< |S )Nauthorized_operationsfields   namebitfieldtype   r   )clsjsonr   r   r   
json_patch   s
   zMetadataResponse.json_patchN)r   r   r   classmethodr#   r   r   r   r   r      s    r   N)	
__future__r   api_messager   
kafka.utilr   r   r   __all__r   r   r   r   <module>   s    