o
    `šj~  ã                   @  sD   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é   )Ú
ApiMessagec                   @  s   e Zd Zddd„ZdS )ÚProduceRequestÚreturnÚboolc                 C  s   | j dkrdS dS )Nr   FT)Úacks)Úself© r
   ú]/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/producer/produce.pyÚexpect_response   s   
zProduceRequest.expect_responseN)r   r   )Ú__name__Ú
__module__Ú__qualname__r   r
   r
   r
   r   r      s    r   c                   @  s   e Zd ZdS )ÚProduceResponseN)r   r   r   r
   r
   r
   r   r      s    r   N)Ú
__future__r   Úapi_messager   r   r   Ú__all__r
   r
   r
   r   Ú<module>   s    ÿ