如何配置Vagrant实现Windows宿主机与Ubuntu虚拟机中kafka-docker通信？

我太懂这种“看起来连得上但就是没动静”的糟心情况了——核心问题出在Kafka的**公告监听器（Advertised Listeners）**配置上。当你用network_mode: host让Kafka跑在虚拟机的网络里时，它默认只会把虚拟机内部的localhost地址告诉客户端。Windows宿主机的程序虽然能通过端口转发或者虚拟机IP连上Kafka，但Kafka会把自己的内部地址返回给客户端，宿主机根本找不到这个地址，自然就收不到消息也发不出去了。

下面是具体的解决步骤，一步步来就能搞定：

1. 获取Vagrant虚拟机的IP地址 #

先SSH进你的Vagrant虚拟机：

vagrant ssh

然后执行ip addr或者ifconfig（取决于Ubuntu版本），找到虚拟机的对外IP——通常是类似192.168.56.101这种（Vagrant默认的私有网络IP段），记下来这个地址。

2. 修改docker-compose.yml的Kafka配置 #

把你原来的docker-compose.yml更新成下面的内容，记得把<虚拟机IP>替换成你刚查到的实际地址：

version: '2'
services:
  zookeeper:
    image: "wurstmeister/zookeeper:latest"
    network_mode: "host"
    ports:
      - "2181:2181"
  kafka:
    image: "wurstmeister/kafka:latest"
    network_mode: "host"
    ports:
      - "9092:9092"
    environment:
      # 对外公布两个监听地址：内部用localhost，宿主机用虚拟机IP
      KAFKA_ADVERTISED_LISTENERS: INSIDE://localhost:9092,OUTSIDE://<虚拟机IP>:9092
      # 定义每个监听器的安全协议（这里都用明文）
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
      # Kafka实际监听所有网卡的9092端口
      KAFKA_LISTENERS: INSIDE://0.0.0.0:9092,OUTSIDE://0.0.0.0:9092
      # Broker之间内部通信用INSIDE监听器
      KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE
      KAFKA_ZOOKEEPER_CONNECT: localhost:2181

3. 重启Kafka和Zookeeper服务 #

进入docker-compose.yml所在的目录，先停掉旧服务，再启动新的：

docker-compose down
docker-compose up -d

4. 调整Windows宿主机的NodeJS客户端配置 #

把你客户端代码里的broker地址改成虚拟机的IP，而不是localhost：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-host-app',
  brokers: ['192.168.56.101:9092'] // 替换成你的虚拟机实际IP
})

额外注意事项 #

• 如果你的Vagrant用的是端口转发模式，记得在Vagrantfile里加上端口转发规则，确保宿主机能访问9092和2181端口：

config.vm.network "forwarded_port", guest: 9092, host: 9092
config.vm.network "forwarded_port", guest: 2181, host: 2181

这种情况下你也可以用localhost:9092访问，但用虚拟机IP更稳定。

• 检查Ubuntu虚拟机的防火墙，确保9092和2181端口是开放的，比如执行sudo ufw allow 9092/tcp和sudo ufw allow 2181/tcp。

这样调整之后，Windows宿主机的NodeJS程序应该就能正常生产和消费Kafka消息了！

内容的提问来源于stack exchange，提问作者Bertrand_Szoghy