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

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

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

kafka
发表于 2020-04-23
林开心
添加评论

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

回复
回答于 4年前
半兽人
林开心 -> 半兽人 4年前

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

0 0 回复
半兽人 -> 林开心 4年前

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

0 0 回复
林开心 -> 半兽人 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

0 0 回复
半兽人 -> 林开心 4年前

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

0 0 回复
林开心 -> 半兽人 4年前

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

0 0 回复
半兽人 -> 林开心 4年前

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

0 0 回复
林开心 -> 半兽人 4年前

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

0 0 回复
你的答案

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

找不到想要的答案？提一个您自己的问题。