diff --git a/models/__init__.py b/models/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/settings.py b/settings.py
index 674b684..2e6afbd 100644
--- a/settings.py
+++ b/settings.py
@@ -10,7 +10,7 @@ class Config:
     SALT = '0r4X00mH'
     KAFKA_CONF = {
         'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
-        'value_serializer': lambda v: json.dumps(v).encode('utf-8'),
+        'value_serializer': lambda v: v.encode('utf-8'),
     }