10 lines
372 B
Python
10 lines
372 B
Python
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
|