Я построил изображение докера для kafka (wurstmeister/kafka-docker). Внутри контейнера докеров я могу создавать темы, создавать сообщения и потреблять сообщения, используя встроенные сценарии оболочки. Теперь я использую код, размещенный на https://github.com/mapr-demos/kafka-sample-programs, чтобы подключиться к kafka broker с моей главной машины. После создания и запуска программы ничего не происходит, а программа запускается. Я думаю, продюсер.send не может подключиться к kafka broker. Подсказка:Код java для производителя/потребителя не может подключиться kafka в настройке докера
1
A
ответ
1
Вы можете видеть, что как consumer.properties
, так и producer.properties
файлов в этом проекте указать bootstrap.servers=localhost:9092
.
Поскольку вы не можете подключиться к dockerized службы Кафки с помощью localhost:9092
, вы можете попытаться найти IP-адрес контейнера Docker, используя, например, docker inspect kafka | grep IPA
(при условии, что имя вашего контейнера kafka
). Затем замените localhost
на этот IP-адрес в этих двух файлах свойств.
1
Я использую изображение док-станции ches/kafka. Взгляните на объяснение KAFKA_ADVERTISED_HOST_NAME.
Смежные вопросы
- 1. kafka spout не может подключиться к kafka теме
- 2. kafka-python: производитель не может подключиться
- 3. Библиотека Elasticsearch-Hadoop не может подключиться к контейнеру докера
- 4. второй сеанс ssh не может подключиться к хосту докера
- 5. Код java потребительского кода Kafka не работает
- 6. Компилятор Java не может найти класс Kafka
- 7. Потребитель Kafka не может начать
- 8. Публикация сообщения Kafka, работающего внутри докера
- 9. подключиться к работающему контейнеру докера
- 10. Взаимодействие с контейнером для док-станции kafka снаружи хост-докера
- 11. Java не может подключиться к MySQL-серверу
- 12. Не удается подключиться к удаленному продюсеру Kafka из окон через java-код
- 13. SignalR java не может подключиться к серверу
- 14. Почему производитель kafka 0.10 не может отправлять сообщения kafka 0.9?
- 15. pykafka не может подключиться Кафка брокера
- 16. Java RMI не может подключиться к реестру
- 17. Почему я не могу подключиться к Kafka/Zookeeper? (В докере)
- 18. Журналы Solr не нажимаются непосредственно на kafka, Solr не может подключиться к ZK
- 19. Не удается подключиться к mongodb в контейнере докера
- 20. Java не может подключиться к сокету сервера
- 21. Секретные тома не работают при настройке многоузлового докера
- 22. MySQL не может подключиться
- 23. Как общаться с сервером Kafka, работающим внутри докера
- 24. Весна не может подключиться к контейнеру selenium докера для запуска capybara через rspec
- 25. Cloudera Kafka не может работать
- 26. Нужен код Java для использования Confluent kafka connect HDFS API
- 27. Kafka Clients jar JAVA
- 28. Публикация сообщения внешнему Kafka Broker из контейнера-докера
- 29. WinSock не может подключиться
- 30. гнездо не может подключиться
Чтобы проверить, является ли проблема с сетью, можете ли вы попытаться установить telnet через порты, где запущены zookeeper/brokers? Для этого: «telnet 2181» и «telnet 9092». –
@ jose.goncabel Я могу использовать telnet zookeeper, но не брокер с моей главной машины. Как это можно исправить – maverick
Я хотел бы вам помочь, но у меня нет опыта работы с сетью Docker, насколько я могу вам судить, вы столкнулись с сетевой проблемой. Однако я бы рекомендовал вам переписать свой вопрос, чтобы понять, как выглядит ваша структура. Где работают зоопарк, брокеры, потребители и производители, в контейнере докера или из него. –