kafka на сервере A, однако потребитель в B-сервере [дубликат]
Для меня работала переустановка модуля mcrypt.
$sudo apt-get install php5-mcrypt
$sudo php5enmod mcrypt
4 ответа
В вашей kafka server.properties есть прокомментированная конфигурация
#advertised.host.name=<Some IP>
Раскомментируйте это и добавьте IP-адрес Linux-машины, в которой работает kafka.
advertised.host.name=<Kafka Running Machine IP>
И подключиться от клиентов к <Kafka Running Machine IP> Это должно исправить вашу проблему.
EDIT
Возможно, вы можете раскомментировать
#advertised.port=9092
Также, если вы слушаете другой порт, чем стандартный.
-
1Спасибо, это работает! – itaied 26 January 2015 в 09:45
-
2Нужно ли также менять конфигурацию zookeeper? Потому что у меня все еще проблема – xXxpRoGrAmmErxXx 23 May 2016 в 23:58
-
3Я должен был указать как host.name, так и advertised.host.name, чтобы он работал. – Rahul 11 August 2016 в 00:52
-
4– Robin Moffatt 21 August 2018 в 12:44
Пробовал подключиться к удаленному кластеру kafka с моей локальной машины.
У VM было 1 внутреннее (9.0.0.1 и внешнее ip (192.1.1.1), я мог бы ssh только внутреннему & amp; не внешнему, изменения в моем файле conifg / server.properties
// предоставить ip в машине, когда u делает ifconfig или hostname -I
listeners=PLAINTEXT://192.1.1.1:9092
// дает ip-потребителю и производителю connect
advertised.listeners=PLAINTEXT://9.0.0.1:9092
Работает с
из server.properties Uncomment
listeners=PLAINTEXT://:9092
И
advertised.listeners=PLAINTEXT://<HOST IP>:9092
Замените <HOST IP> на фактический IP.
-
1
-
2Пробовал подключиться к удаленному кластеру kafka из VM. VM имеет 1 внутренний (9.0.0.1 и внешний ip (192.1.1.1), я мог бы ssh только для внутреннего и не внешнего, изменения в моем файле conifg / server.properties // выдавать ip в машине, когда u делает ifconfig или hostname -I 'code' listeners = PLAINTEXT: //192.1.1.1: 9092 // дать ip-потребителю и продюсеру подключить 'code' advertized.listeners = PLAINTEXT: //9.0.0.1: 9092 – CodeUrLife 4 September 2017 в 09:29