用k8s搭建了三台kafka集群(分在三个服务器上),搭建后建立topic,使用kafka自带topic命令describe查看topic,所有partition都有leader。但使用生产消费命令的时候提示Broker may not be available.
第一次是警告,然后会创建成功的。
现在是在zk里可以看到三个节点,然后创建topic也正常,每个broker都有对应topic的文件目录,然后用生产者和消费者就会报没有topic或者partition的错误
贴一下完整的错误吧。初步怀疑是 listeners="ip"的问题。
没办法贴图了,这是昨天的错误:
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
[宿主机外网口IP] 要换成内网。
是要换成容器分配的IP吗?
对,容器化的话,感觉你是要用service,如(kafka-1,kafka-2)
可参考:https://www.orchome.com/1813
现在发现启动配置 containerPort
下标签用 hostPort 是可以的
你的答案