Я пытаюсь получить доступ к серверу Kafka (10.10.45.91) с удаленного хоста (10.10.45.90).
Виртуальные машины Alma Linux 9.x, Kafka Kraft 2.13-3.7.1 как на сервере, так и на удаленном хосте.
Что я сделал:
Я добавил тему logstash-topic
FW: открыть порт 9092
Установите конфигурацию:
sudo nano /opt/kafka/config/server.properties
Работает как надо
nc -vz 19.10.45.91 9092 => ok
=> Ошибка при выполнении команды темы: Тема 'logstash-topic' не существует, как ожидалось...
Почти уверен, что это потому, что она обращается к локальной kafka (удалённой стороне)
Примечание: Когда я запускаю logstash с правильной конфигурацией (которая хорошо работает на виртуальной машине сервера), Logstash, похоже, "запрашивает" localhost.
Я думаю, что мой сервер Kafka не отправляет правильный IP-адрес хоста.
Кажется, я получил ошибку в моём файле конфигурации Kafka.
Я перепробовал много конфигураций в полях listeners, advertised.listeners и listener.security.protocol.map.
Возможно, что-то работает не с IP-адресом, а с именем хоста, но я не могу выяснить.
2 дня потратил на эту проблему, читая посты и S.O., теперь мне нужна помощь :).
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://10.10.45.91:9092
/opt/kafka/bin/kafka-topics.sh --bootstrap-server 19.10.45.91:9092 --describe --topic logstash-topic
/opt/kafka/bin/kafka-topics.sh --bootstrap-server 19.10.45.91:9092 --describe --topic logstash-topic