#!/app/python/bin/python
from kafka import KafkaConsumer
consumer = KafkaConsumer('test',bootstrap_servers=['$HOSTNAME:9093'])
for message in consumer:
print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,
message.offset, message.key,
message.value))
