"""Base Deserialization Class.""" class BaseDeserializer: """Base Deserializer.""" def deserialize(self, value, topic=None, context=None): """Deserialize.""" raise NotImplementedError() def get_schema_id(self, serialized_msg): """Get the schema ID from the serialized message.""" return 0