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)

Он подключается, но не может напечатать какое-либо сообщение, застревает и не отображается вообще. Из командной строки все отлично работает. Что я делаю не так?

0 ответов

Другие вопросы по тегам