生产者/消费者的java代码无法在docker设置中连接kafka

Question

我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用托管在https://github.com/mapr-demos/kafka-sample-programs上的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么也不会发生，程序就会卡住。我猜producer.send无法连接到kafka broker。任何帮助我们都将不胜感激

Answer 1

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

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

Answer 2

我使用的是ches/kafka docker image。看一下KAFKA_ADVERTISED_HOST_NAME的解释。