может использовать kafka broker ip у потребителя или производителя?

Question

У меня есть две машины localhost и 192.168.1.110 для запуска двух независимых одиночных машин kafka.

(1) На локальном хосте, я бегу:

➜ kafka_2.11-0.10.0.0 бен/kafka-console-producer.sh --broker-лист 192.168.1.110:9092 --topic тест это это сообщение [2016-08-24 18: 15: 27,441] ERROR Ошибка при отправке сообщения в тему test с ключом: null, value: 2 байта с ошибкой: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: Batch, содержащее 1 запись (ей) истек из-за тайм-аут при запросе метаданных из брокеров для теста-0

Почему сообщение не может быть отправлено в качестве посредника на 192.168. 1,110? Могу ли я использовать брокерский ip непосредственно у потребителя или производителя? Если бы я мог использовать только имя хоста, относится ли это к объявленному.host.name? , то как настроить advertised.host.name? делает это имя хоста должно быть глобально разрешимой (я мог использовать/и т.д./хосты разрешить имя хоста?)

(2) я редактировал/и т.д./хосты, чтобы позволить точку локального хоста на 192.168.1.110, тогда я бегу : ➜ kafka_2.11-0.10.0.0 бен/kafka-console-producer.sh --broker-лист локальный: 9092 --topic тест

и я мог успешно отправленных сообщений в 192.168.1.110 и потребляли сообщения там ,

(3) Я редактировал/и т.д./хосты, чтобы rrlocalhost точку 192.168.1.110, затем я бегу: ➜ kafka_2.11-0.10.0.0 бен/kafka-console-producer.sh --broker-лист rrlocalhost: 9092 --topic test

Затем я отправил сообщения в rrlocalhost, там же ошибка, что и в (1).

Answer 1

Определенно вы можете использовать ip-адрес напрямую.

брокер конфигурации advertised.host.name будет зарегистрирован в zookeeper, а производитель и потребитель получат их как кластерные метаданные. Если вы настроите его с использованием имени локального псевдонима, у производителя и потребителя возникнет проблема с ним.