kafka-experiments/consume.py

10 lines
372 B
Python
Raw Permalink Normal View History

2022-12-03 01:20:52 +00:00
from kafka import KafkaConsumer
from config import CONFIG, GROUP_ID
consumer = KafkaConsumer('chat', group_id=GROUP_ID, auto_offset_reset='earliest', enable_auto_commit=True, **CONFIG)
try:
for message in consumer:
print("%d:%d: %s := %s" % (message.partition, message.offset, message.key.decode(), message.value.decode()))
except KeyboardInterrupt:
pass