from pykafka import KafkaClient

client = KafkaClient(hosts="127.0.0.1:9092")
topic = client.topics["interview"]
consumer = topic.get_simple_consumer()
for message in consumer:
    if message is not None:
        print("Offset: {} Value {}".format(message.offset, message.value))

30d63b2745c3685a2a2bdeef28675f238ae36c82
<mask token>

<mask token>
for message in consumer:
    if message is not None:
        print('Offset: {} Value {}'.format(message.offset, message.value))

<mask token>
client = KafkaClient(hosts='127.0.0.1:9092')
topic = client.topics['interview']
consumer = topic.get_simple_consumer()
for message in consumer:
    if message is not None:
        print('Offset: {} Value {}'.format(message.offset, message.value))

from pykafka import KafkaClient
client = KafkaClient(hosts='127.0.0.1:9092')
topic = client.topics['interview']
consumer = topic.get_simple_consumer()
for message in consumer:
    if message is not None:
        print('Offset: {} Value {}'.format(message.offset, message.value))

from pykafka import KafkaClient

client = KafkaClient(hosts="127.0.0.1:9092")
topic = client.topics["interview"]
consumer = topic.get_simple_consumer()
for message in consumer:
    if message is not None:
        print("Offset: {} Value {}".format(message.offset, message.value))
