from pykafka import KafkaClient

client = KafkaClient(hosts='127.0.0.1:9092')
for i in client.topics[topicname].get_simple_consumer():
    print ('data:{0}\n\n'.format(i.value.decode()))