
    Ii                     D    S SK Jr  S SKr " S S\5      r " S S\5      rg)    )absolute_importNc                   \    \ rS rSr\R
                  rS r\R                  S 5       r	S r
Srg)
Serializer   c                     g N selfconfigs     ?/venv/lib/python3.13/site-packages/kafka/serializer/abstract.py__init__Serializer.__init__	           c                     g r   r	   )r   topicvalues      r   	serializeSerializer.serialize       r   c                     g r   r	   r   s    r   closeSerializer.close   r   r   r	   N)__name__
__module____qualname____firstlineno__abcABCMeta__meta__r   abstractmethodr   r   __static_attributes__r	   r   r   r   r      /    {{H 	 r   r   c                   \    \ rS rSr\R
                  rS r\R                  S 5       r	S r
Srg)Deserializer   c                     g r   r	   r
   s     r   r   Deserializer.__init__   r   r   c                     g r   r	   )r   r   bytes_s      r   deserializeDeserializer.deserialize   r   r   c                     g r   r	   r   s    r   r   Deserializer.close   r   r   r	   N)r   r   r   r   r    r!   r"   r   r#   r-   r   r$   r	   r   r   r'   r'      r%   r   r'   )
__future__r   r    objectr   r'   r	   r   r   <module>r3      s#    & 
 6 r   