Как исправить то, что не получал сообщения кафки в python, а получал те же сообщения в оболочке? - PullRequest
Новая
       17

Как исправить то, что не получал сообщения кафки в python, а получал те же сообщения в оболочке?

0 голосов
/ 15 апреля 2019

Я хочу использовать сообщения, приходящие в теме кафки.Я использую debezium, который выдает изменения mongodb и помещает их в очередь kafka.Я могу подключиться к kafka, используя мой код на python, перечислить темы по kafka.Хотя, когда я хочу использовать сообщения, все это пусто, тогда как одна и та же тема при использовании из оболочки дает сообщения, работает отлично. 

from kafka import KafkaConsumer

topic = "dbserver1.inventory.customers"
# consumer = KafkaConsumer(topic, bootstrap_servers='localhost:9092', auto_offset_reset='earliest', auto_commit_enable=True)
consumer = KafkaConsumer(topic)
print("Consumer connected!")
# print("Topics are {}".format(consumer.topics()))
for message in consumer:
    print(message)
...