我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中,我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在,我使用托管在上的代码从我的主机连接到kafka broker。在构建和运行程序之后,什么也不会发生,程序就会卡住。我猜producer.send无法连接到kafka b
当我尝试我的Kafka经纪人时,记录一条错误消息。我使用默认的server.properties文件进行以下更改:advertised.listeners=PLAINTEXT://192.168.0.109:9092其中192.168.0.109是我的主机IP。# start kafka with customer server