pykafka: невозможно получить сообщения
Так что я впервые в Kafka и пробую разные Python-библиотеки. Итак, я пытаюсь следующий код:
from pykafka import KafkaClient
if __name__ == '__main__':
client = KafkaClient(hosts="0.0.0.0:9092")
print(client.topics)
topic = client.topics[b'DAILY_SALES']
consumer = topic.get_simple_consumer()
for message in consumer:
print(message.offset, message.value)
Он подключается, но не может напечатать какое-либо сообщение, застревает и не отображается вообще. Из командной строки все отлично работает. Что я делаю не так?