# Collection of code snippets by Arne Vajhøj 
# (from articles on eksperten.dk / vajhoej.dk written sometime between 2004 and now) 
from kafka import KafkaConsumer

SERVER = 'localhost:9092'
TNAME = 'TestT'
consumer = KafkaConsumer(bootstrap_servers=SERVER)
consumer.subscribe([TNAME])
for message in consumer:
    print('%s:\r\n%s\r\n' % (message.key,message.value))