MetaData Response - имя хоста брокера неверно

Question

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

(Broker metadata, Topic metadata) 

метаданных Брокер приходит как,

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

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

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

Answer 1

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

Там есть строка в вашем брокер server.properties:

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

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