1、问题描述
在虚拟机CentOS-7上搭建的Docker Kafka ,docker内部可以创建Topic、可以生产者数据、可以消费数据，而在宿主机开发程序无法消费Docker Kafka的数据。
1.1、运行情况
[docker@localhost ~]$ docker ps -a
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
c894cb467f23 wurstmeister/kafka "start-kafka.sh" 19 minutes ago Up 19 minutes 0.0.0.0:9092->9092/tcp, :::9092->9092/tcp kafka
ca4c190038ea zookeeper "/docker-entrypoint.…" 58 minutes ago Up 58 minutes 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp, :::2181->2181/tcp, 8080/tcp zookeeper1.2、生产数据
[docker@localhost ~]$ docker exec -it kafka kafka-console-producer.sh --broker-list 192.168.33.231:9092 --topic test
>123
>345
>2024-06-07
1.3、消费数据
[docker@localhost ~]$ docker exec -it kafka kafka-console-consumer.sh --bootstrap-server 192.168.33.231:9092 --topic test --from-beginning
123
345
2024-06-07
2、问题分析
2.1、docker 配置
docker run -d --name kafka --publish 9092:9092 \
--link zookeeper \
--env KAFKA_ADVERTISED_HOST_NAME=192.168.33.231 \
--env KAFKA_ZOOKEEPER_CONNECT=192.168.33.231:2181 \
--env KAFKA_ADVERTISED_PORT=9092 \
--env KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.33.231:9092 \
--env KAFKA_LISTENERS=PLAINTEXT://:9092 \
--env KAFKA_LOG_DIRS=/kafka/kafka-logs-1 \
-v /bigdata/kafka_data/data:/kafka/kafka-logs-1 \
wurstmeister/kafka2.2.端口查看
[docker@localhost ~]$ lsof -i:9092
[docker@localhost ~]$
[docker@localhost ~]$
[docker@localhost ~]$
[docker@localhost ~]$
[docker@localhost ~]$
[docker@localhost ~]$
[docker@localhost ~]$ netstat -tunlp | grep 9092
(Not all processes could be identified, non-owned process info
will not be shown, you would have to be root to see it all.)
tcp 0 0 0.0.0.0:9092 0.0.0.0:* LISTEN -
tcp6 0 0 :::9092 :::* LISTEN -
2.3、原因分析
1）配置原因
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://139.226.179.239:9092
把kafka的地址端口注册给zookeeper，若远程访问要改成外网IP,千万注意是外网IP，很多文章只说是宿主机IP, 演示例子上写的是内网IP，很容易被误导
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092
配置kafka的监听端口
2）虚拟机防火墙
- 查看防火墙是否开启
systemctl status firewalld
- 开启防火墙
firewall-cmd --list-ports
- 重启防火墙
firewall-cmd --reload
- 启动防火墙后，默认没有开启任何端口，需要手动开启端口
firewall-cmd --zone=public --add-port=9092/tcp --permanent
参数：--zone (作用域)
--add-port=9092/tcp (添加端口，格式：端口/通讯协议）
--permanent (永久生效，没有此参数重启后失效）
3、解决方法
3.1、关闭虚拟机防火墙
systemctl stop firewalld.service
3.2、添加宿主机到Docker的路由
以管理员身份运行CMD,添加如下路由
route add -p 172.17.0.2 mask 255.255.0.0 192.168.33.231
3.3、打开虚拟机NET网卡配置
添加宿主机和虚拟机网卡 端口转发如图：
4、结论：
本机-宿主机程序直接发送数据
Docker kafka 数据：
