我为Kafka建立了一个docker映像（wurstmeister/kafka docker）。在docker容器中，我可以使用内置shell脚本创建主题、生成消息和使用消息。现在我正在使用托管在https://github.com/mapr-demos/kafka-sample-programs 从我的主机连接到kafka代理。在构建和运行程序之后，什么都不会发生，程序也不会停止。我想producer.send无法连接到kafka broker。感谢您的帮助
我为Kafka建立了一个docker映像（wurstmeister/kafka docker）。在docker容器中，我可以使用内置shell脚本创建主题、生成消息和使用消息。现在我正在使用托管在https://github.com/mapr-demos/kafka-sample-programs 从我的主机连接到kafka代理。在构建和运行程序之后，什么都不会发生，程序也不会停止。我想producer.send无法连接到kafka broker。感谢您的帮助
2条答案
按热度按时间h5qlskok1#
我使用的是ches/kafka docker图像。看一下Kafka的解释。
zujrkrfu2#
你可以看到
consumer.properties以及producer.properties该项目中的文件指定bootstrap.servers=localhost:9092.因为您无法使用连接到停靠的kafka服务
localhost:9092，您可以尝试查找docker容器的ip地址，例如，docker inspect kafka | grep IPA（假设您的容器名称为kafka). 然后更换localhost在这两个属性文件中的ip地址。