update data

requirements.txt

@@ -6,3 +6,7 @@ scikit-learn==0.23.1
 numba==0.50.1
 
 redis==2.10.5
+
+kafka-python
+python-snappy
+lz4

src/online_prediction.py

@@ -9,8 +9,10 @@ def consume_kafka():
 
     consumer.subscribe(["gm-portrait-update-device"])
 
-    for msg in consumer:
-        print(msg)
+    message = consumer.consume_data()
+
+    for msg in message:
+        print(msg.value)
 
 
 if __name__ == "__main__":