Невозможно подключиться к удаленному брокеру kafka даже после настройки объявленных слушателей - PullRequest
1 голос
/ 28 мая 2020

У меня есть виртуальная машина, созданная в GCP, и я настраиваю в ней kafka. Я изменил рекламируемых слушателей на внешний publi c ip виртуальной машины.

enter image description here

Но когда я пытаюсь подключиться с локального ноутбука Я все время получаю эту ошибку.

enter image description here

Я проверил подключение к машине с помощью команды ping и получаю ответ

PING 34.69.37.118 (34.69.37.118): 56 data bytes
64 bytes from 34.69.37.118: icmp_seq=0 ttl=54 time=266.223 ms
64 bytes from 34.69.37.118: icmp_seq=1 ttl=54 time=290.133 ms
64 bytes from 34.69.37.118: icmp_seq=2 ttl=54 time=264.678 ms
64 bytes from 34.69.37.118: icmp_seq=3 ttl=54 time=263.067 ms
^C
--- 34.69.37.118 ping statistics ---
4 packets transmitted, 4 packets received, 0.0% packet loss
round-trip min/avg/max/stddev = 263.067/271.025/290.133/11.088 ms

1 Ответ

1 голос
/ 28 мая 2020

Если ваш клиент (Kafka Producer) находится за пределами виртуальной машины, вам необходимо предоставить следующее:

listeners=INTERNAL://0.0.0.0:19092,EXTERNAL://0.0.0.0:9092
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
advertised.listeners=INTERNAL://vm-address:19092,EXTERNAL://host-address:9092
inter.broker.listener.name=INTERNAL

Теперь ваш производитель должен использовать 19092

...