报错内容

error connecting to node 0 at kafka-0.kafka-headless.local:9092

其实就是没有连接上kafka

我是把svc作为nodeport暴露端口出来,去连接这个端口然后报错了。

遇到这种情况,不要怀疑自己,一定是kafka的配置问题。

kafka默认配置是不允许外部连接访问的,只允许localhost,部署的时候一定要修改配置

两种解决办法

1.修改conf/server.perporties

brokerIP 替换为 当前broker的IP。
//每台broker的server.properties 添加如下。
listeners=PLAINTEXT://brokerIP:9092

2.如果是在k8s部署的,就修改官方的charts

修改values.yaml

在这里插入图片描述
external:顾名思义就是对外的意思
根据里面的注释修改配置,尤其是如下这个配置。
在这里插入图片描述

Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐