kafka consumer

kafka/consumer.py

@@ -1,3 +1,21 @@
 #!/usr/bin/env python3
 from datetime import datetime
 
+from kafka import KafkaConsumer
+
+
+DATETIMES=[]
+
+
+consumer = KafkaConsumer(bootstrap_servers='localhost:9092', auto_offset_reset='earliest', consumer_timeout_ms=1000)
+consumer.subscribe(['test'])
+
+
+try:
+    while True:
+        for message in consumer:
+            DATETIMES.append(datetime.now())
+    consumer.close()
+except Exception:
+    consumer.close()
+    print(DATETIMES)