o
    `šjó  ã                   @   s&   d dl mZmZ G dd„ deeƒZdS )é   )Ú
SerializerÚDeserializerc                   @   s&   e Zd Zd	dd„Zdd„ Zdd„ ZdS )
ÚDefaultSerializerúutf-8c                 C   s
   || _ d S ©N)Úencoding)Úselfr   © r	   úV/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/serializer/default.pyÚ__init__   s   
zDefaultSerializer.__init__c                 C   s(   t |ƒtttt d ƒfv r|S | | j¡S r   )ÚtypeÚbytesÚ	bytearrayÚ
memoryviewÚencoder   ©r   ÚtopicÚheadersÚdatar	   r	   r
   Ú	serialize   s   zDefaultSerializer.serializec                 C   s   |d u rd S |  | j¡S r   )Údecoder   r   r	   r	   r
   Údeserialize   s   zDefaultSerializer.deserializeN)r   )Ú__name__Ú
__module__Ú__qualname__r   r   r   r	   r	   r	   r
   r      s    
r   N)Úabstractr   r   r   r	   r	   r	   r
   Ú<module>   s    