try get data from kafka

src/online_prediction.py

+from kafka import KafkaConsumer
+
+
+def consume_kafka():
+    consumer = KafkaConsumer(bootstrap_servers="172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092",
+                             group_id="essm_online_prediction",
+                             enable_auto_commit=True,
+                             auto_commit_interval_ms=500000)
+
+    consumer.subscribe(["gm-portrait-update-device"])
+
+    for msg in consumer:
+        print(msg)
+
+
+if __name__ == "__main__":
+    consume_kafka()