Source code for kafka.serializer.default

from .abstract import Serializer, Deserializer



[docs]
class DefaultSerializer(Serializer, Deserializer):
    def __init__(self, encoding='utf-8'):
        self.encoding = encoding


[docs]
    def serialize(self, topic, headers, data):
        if type(data) in (bytes, bytearray, memoryview, type(None)):
            return data
        return data.encode(self.encoding)



[docs]
    def deserialize(self, topic, headers, data):
        if data is None:
            return None
        return data.decode(self.encoding)