"""String Deserializer.""" from kafka_utils.consumer.deserializer.base import BaseDeserializer class StringDeserializer(BaseDeserializer): """String Deserializer.""" def deserialize(self, value, topic=None, context=None): """Deserialize.""" return value.decode('utf_8')