get data

src/online_prediction.py

@@ -11,8 +11,9 @@ def consume_kafka():
     consumer.subscribe(["gm-portrait-update-device"])
 
     for msg in consumer:
-        print(msg.value)
-        print(json.loads(msg.value), "\n")
+        data = json.loads(msg.value)
+        device_id = data.get("device_id", "")
+        print(device_id)
 
 
 if __name__ == "__main__":