K8S 搭建kakfa集群,外部访问失败

林开心 发表于: 2020-04-23   最后更新时间: 2020-04-23 20:43:46   2,297 游览

用k8s搭建了三台kafka集群(分在三个服务器上),搭建后建立topic,使用kafka自带topic命令describe查看topic,所有partition都有leader。但使用生产消费命令的时候提示Broker may not be available.

发表于 2020-04-23
添加评论

第一次是警告,然后会创建成功的。

林开心 -> 半兽人 4年前

现在是在zk里可以看到三个节点,然后创建topic也正常,每个broker都有对应topic的文件目录,然后用生产者和消费者就会报没有topic或者partition的错误

半兽人 -> 林开心 4年前

贴一下完整的错误吧。初步怀疑是 listeners="ip"的问题。

林开心 -> 半兽人 4年前

没办法贴图了,这是昨天的错误:
WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 1 : {test5=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
kafka的配置是:
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://[宿主机外网口IP]:9092

半兽人 -> 林开心 4年前

[宿主机外网口IP] 要换成内网。

林开心 -> 半兽人 4年前

是要换成容器分配的IP吗?

半兽人 -> 林开心 4年前

对,容器化的话,感觉你是要用service,如(kafka-1,kafka-2)
可参考:https://www.orchome.com/1813

林开心 -> 半兽人 4年前

现在发现启动配置 containerPort
下标签用 hostPort 是可以的

你的答案

查看kafka相关的其他问题或提一个您自己的问题