o
    `šj5  ã                   @   s8   d dl mZ G dd„ deƒZG dd„ deƒZddgZdS )é   )Ú
ApiMessagec                   @   s   e Zd Zedd„ ƒZdS )ÚFetchRequestc                 C   s   t |ƒdkrdS dS )Né    é   )Úint)ÚclsÚil© r	   ú[/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/consumer/fetch.pyÚmin_version_for_isolation_level   s   z,FetchRequest.min_version_for_isolation_levelN)Ú__name__Ú
__module__Ú__qualname__Úclassmethodr   r	   r	   r	   r
   r      s    r   c                   @   s   e Zd ZdS )ÚFetchResponseN)r   r   r   r	   r	   r	   r
   r      s    r   N)Úapi_messager   r   r   Ú__all__r	   r	   r	   r
   Ú<module>   s
    ÿ