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