Ответ метаданных - неправильное имя хоста брокера

Я использую SimpleConsumer python-kafka для прослушивания темы в брокере kafka. Брокер Kafka работает на машине с именем хоста BROKER_HOST. Теперь SimpleConsumer запрашивает метаданные темы у брокера BROKER_HOST для темы TOPIC и получает кортеж.

   (Broker metadata, Topic metadata)

Метаданные брокера выглядят так:

 {0: BrokerMetadata(nodeId=0, host='localhost', port=9092)}

и в идеале значение хоста должно быть BROKER_HOST (hostname командная строка оболочки подтверждает это), но это локальный хост...

``Как метаданные брокера для темы попадают в систему kafka? И, очевидно, это ломает систему, поскольку мой потребитель пытается подключиться к 9092 на своем локальном хосте.


apache-kafka kafka-consumer-api akka-kafka
person Community    schedule 11.02.2015    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Похоже, ваш брокер неправильно рекламирует себя.

В server.properties вашего брокера есть строка:

#advertised.host.name=<hostname routable by clients>

Вы должны раскомментировать его и установить значение, маршрутизируемое вашим потребителем, и перезапустить брокера.

person serejja    schedule 11.02.2015