docker - 生产者/消费者的Java代码无法在Docker安装程序中连接kafka

Question

我已经为kafka(wurstmeister / kafka-docker)构建了一个docker镜像。在docker容器内部，我能够使用内置的shell脚本创建主题，生成消息并使用消息。现在，我正在使用https://github.com/mapr-demos/kafka-sample-programs托管的代码从主机连接到kafka代理。生成并运行程序后，什么也没有发生，并且程序卡住了。我猜producer.send无法连接到kafka经纪人。任何帮助表示赞赏

Answer 1

您可以看到该项目中的consumer.properties和producer.properties文件都指定了bootstrap.servers=localhost:9092。

由于您无法使用localhost:9092连接到dockerized kafka服务，因此您可以尝试使用docker inspect kafka | grep IPA查找docker容器的IP地址(假设您的容器名称为kafka)。然后在这两个属性文件中用该IP地址替换localhost。