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

发表于: 2020-04-23   最后更新时间: 2020-04-23  

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



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: kafka C程序Producer堆积
下一条: kafka集群代理

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

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

        • 没办法贴图了,这是昨天的错误:
          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