Невозможно опубликовать в Кафке - PullRequest
Новая
       6

Невозможно опубликовать в Кафке

0 голосов
/ 30 июня 2018

хочу опубликовать в кафке тему Я не могу этого сделать, программа останавливается. Я получаю эту ошибку:

KafkaTimeoutError: Не удалось обновить метаданные через 60 секунд. 

def saveResults(response):
    entities_tweet = response["entities"]
    for entity in entities_tweet:
        try:
            for i in entity_dict:
                for j in entity_dict[i]:
                    if(entity["text"] in j):
                        entity["tweet"] = response["tweet"]
                        entity["tweetId"] = response["tweetId"]
                        entity["timeStamp"] = response["timeStamp"]
                        #entity["userProfile"] = response["userProfile"]
                        future = producer.send('argentina-iceland-june-16-watson', bytes(entity))
                        print("Published.")
                    else:
                        print("All ignored.")
                        future = producer.send('argentina-iceland-june-16-watson', bytes(entity))
                        print("Published")
        except Exception as e:
            print (e)
        finally:
            producer.flush()

Однако это работает: 

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['broker1:1234'])

# Asynchronous by default
future = producer.send('my-topic', b'raw_bytes')

1 Ответ

0 голосов
/ 30 июня 2018

Похоже, что вы используете неверный сервер Boostrap, он должен быть broker1:9092 вместо broker1:1234 ...

...