Я создал кластер (облако Google) с тремя узлами. Zookeeper работает на всех узлах, и я начал Kafka на одном из подчиненных узлов. Я могу общаться (публиковать/потреблять) с любого компьютера в кластере, но когда я пытаюсь подключиться с удаленной машины, я получаю исключение NoBrokersAvailable.Kafka - Fail Connecting Remote Broker - NoBrokersAvailable
Я открыл порты в брандмауэре для тестирования, и я попытался возиться с advertised_host и портом в конфигурации Kafka, но я не могу подключиться.
Какова ожидаемая конфигурация? - Я бы ожидал, имея подходящие значения по умолчанию, что моя конфигурация будет работать как во внутреннем, так и в удаленном корпусе, но это не так. Я не уверен, какая часть конфигурации zookeeper/kafka позволит мне настроить ее. Что делать?
Есть только слишком много вещей, которые он мог be - например, машины могут запускать «iptables». Или, возможно, Zookeeper и Kafka прослушивают немаршрутизированные IP-адреса (например, «10.x.x.x1» или «192.168.x.x') или кто знает, что это может быть. –
Спасибо, Дэвид. Отметил. Я посмотрю в сети, и если я (когда-либо) доберусь до нее, я остановлюсь на этом здесь для записи. – ismisesisko
обновление, но без радости: я упростил ситуацию. Я использовал один узел с zookeeper и kafka. Я использовал конфлюентный дистрибутив kafka, который дает некоторые преимущества. Я тестировал локально и удаленно с сервером REST, который проверяет, что zookeeper настроен правильно и что я могу внешне подключиться к упомянутому серверу отдыха. Когда я запускаю Kafka, я отмечаю строку вывода:> Зарегистрированный брокер 0 на пути/брокерах/идентификаторы/0 с адресами: PLAINTEXT -> EndPoint (cluster-3-m, 9092, PLAINTEXT). Где он говорит «cluster-3-m», я в основном использовал PUBLIC IP. Очевидно, что брокер запущен и связан - клиент python говорит иначе! – ismisesisko