Source code for kafka.serializer.json

import json

from .default import DefaultSerializer




class JsonSerializer(DefaultSerializer):


    def serialize(self, topic, headers, data):
        if data is None:
            return None
        s = json.dumps(data)
        return super().serialize(topic, headers, s)




    def deserialize(self, topic, headers, data):
        if data is None:
            return None
        s = super().deserialize(topic, headers, data)
        return json.loads(s)