Невозможно запустить Python Kafka Producer и Consumer - PullRequest
Новая
       10

Невозможно запустить Python Kafka Producer и Consumer

0 голосов
/ 27 августа 2018

Итак, я написал простую программу kafka, которая отправляет сообщение производителю, но когда я запускаю ее, я получаю сообщение о том, что kafka не удалось обновить метаданные через 60.0 секунд. Было бы здорово, если бы кто-то мог указать, что мне не хватает. 

from kafka import KafkaConsumer, KafkaProducer

class Producer():
    def __init__(self):
        pass

    def start(self):
        print 'In Producer Start'
        producer = KafkaProducer(bootstrap_servers='localhost:9092')

        for _ in range(10):
            producer.send(b"test-topic", b"test")
            producer.send(b"test-topic", b"\xc2Hola, mundo!")

        producer.close()


class Consumer():
    def __init__(self):
        pass

    def start(self):
        consumer = KafkaConsumer(bootstrap_servers='localhost:9092', auto_offset_reset='earliest')
        consumer.subscribe(b"test-topic")

        for message in consumer:
            print message



def main():
    threads = [
        Producer(),
        Consumer()
    ]

    for t in threads:
        t.start()

if __name__ == "__main__":
    main()
...