1、kafka开放外部访问
1.1、修改kafka configMap
修改内容如下
# 修改EXTERNAL_ACCESS_IP变量,值为真实的外网IP
export EXTERNAL_ACCESS_IP=${真实的外网IP}
1.2、重启kafka
# 重启kafka
kubectl rollout restart statefulset kafka -n default
# 查看kafka状态
kubectl get statefulset -n default
1.3、验证kafka的连通性
下载&解压安装kafka安装包
# 验证kafka是否连通
# 进入kafka安装目录
cd kafka
执行如下命令,ip需要替换为展示ip 端口固定为30190/30191/30192
./bin/kafka-topics.sh --bootstrap-server 47.104.95.242:30190,47.104.95.242:30191,47.104.95.242:30192 --list
显示如下内容即可表示连通成功