bigchungusdata/kafka/consumer.py

22 lines
431 B
Python

#!/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)