"""JSON Deserializer."""

import json

from kafka_utils.consumer.deserializer.base import BaseDeserializer


class JSONDeserializer(BaseDeserializer):
    """JSON Deserializer."""

    def deserialize(self, value, topic=None, context=None):
        """Deserialize."""
        return json.loads(value)