o
    `šjÆ  ã                   @   s(   d dl Z ddlmZ G dd„ deƒZdS )é    Né   )ÚDefaultSerializerc                       s(   e Zd Z‡ fdd„Z‡ fdd„Z‡  ZS )ÚJsonSerializerc                    s&   |d u rd S t  |¡}tƒ  |||¡S ©N)ÚjsonÚdumpsÚsuperÚ	serialize©ÚselfÚtopicÚheadersÚdataÚs©Ú	__class__© úS/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/serializer/json.pyr	      s   
zJsonSerializer.serializec                    s&   |d u rd S t ƒ  |||¡}t |¡S r   )r   Údeserializer   Úloadsr
   r   r   r   r      s   
zJsonSerializer.deserialize)Ú__name__Ú
__module__Ú__qualname__r	   r   Ú__classcell__r   r   r   r   r      s    r   )r   Údefaultr   r   r   r   r   r   Ú<module>   s    