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

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 shell cmd подтверждает это) но это localhost...

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

Answer 1

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

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

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

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