Используя здесь быстрый старт
https://kafka.apache.org/quickstart
Я следовал инструкциям, но когда я выполняю
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
, я получаю:
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
Я изменяю список Команда
bin / kafka-themes. sh --list --zookeeper localhost: 2181
Работает нормально.
Я пытаюсь запустить эти образцы
https://github.com/spring-projects/spring-kafka/tree/master/samples
Не работает, и я получаю:
org.springframework.kafka.KafkaException: Timed out waiting to get existing topics; nested exception is java.util.concurrent.TimeoutException
Это происходит на корпоративном / корпоративном ноутбуке
Я делаю те же самые шаги, используя свои личные макросы (Sierra), используя
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
Работает нормально, работают все образцы пружин
На машине не работает:
Я попытался использовать IP, указанный здесь kafka
[2020-02-28 14:12:31,202] WARN [Controller id=0, targetBrokerId=0] Connection to node 0 (/92.242.132.25:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
Как это --bootstrap-server 92.242.132.25:9092 Это не помогло
Кстати, этот IP-адрес (92.242.132.25) не совпадает с тем, который я получаю из ifconfig, а именно:
192.168.1.35
Я попробовал оба варианта, но ничего не помогло.
Однако telnet localhost 9092 подключается.
- Есть идеи, что происходит? Почему
--bootstrap-server localhost:9092 не работает? - Почему IP-адреса (из выходных данных запуска kafka и ifconfig) отличаются?
- Может ли корпоративная ма c -os иметь некоторые ограничения? (firewall et c), что может вызвать это? На вопрос поддержки они сказали нет.