KAFKA：60000 毫秒后无法更新元数据

Question

我是 KAFKA 的新手，我知道在堆栈溢出时已多次问过这个问题，但没有一个解决方案对我有用，所以在这里我想再次问同样的问题来试试运气。我已经在 Centos7 VM 上下载并安装了 KFKA。VM 在我的笔记本电脑上。当我从命令行运行 KAFKA 生产者和消费者时，它工作正常。下一步，我想创建一个 Java Producer，但它总是超时并出现以下异常。    Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.    at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1186)    at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:880)    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:803)    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:690)    at com.soft.teradata.KafkaProducerExample.runProducer(KafkaProducerExample.java:40)    at com.soft.teradata.KafkaProducerExample.main(KafkaProducerExample.java:55)Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.对于 bootstrap.server，我什至尝试过以下操作：props.put("bootstrap.servers", "PLAINTEXT://192.168.xxx.xxx:9092");请注意，我正在笔记本电脑上从 Eclipse 执行 java 代码，而 KAFKA 安装在笔记本电脑的 CENTOS7 VM 上。192.168.xxx.xxx 是 CENTOS7 虚拟机的 IP 地址。我注意到我的笔记本电脑无法访问 192.168.xxx.xxx:9092 (telnet 192.168.xxx.xxx 9092)。我将端口添加到防火墙，但仍然没有成功。firewall-cmd --zone=public --add-port=9092/tcp --permanent        firewall-cmd --reload        firewall-cmd --list-portsKAFKA 的版本是 2.12-2.0.0，我已经将以下 jars 添加到我的 Eclipse Classpath 中：kafka-clients-2.0.0.jarlz4-java-1.4.1.jarslf4j-api-1.7.25.jarsnappy-java-1.1.7.1.jar非常感谢您提前提供帮助:)Regadrs，DIRSHAH。

Answer 1

此错误可能表明该主题不存在，因此您可能需要仔细检查您的 topicName = "Hello-Kafka"。

虽然这不是一个深刻的答案，但它似乎是一个常见问题，另见https://github.com/dpkp/kafka-python/issues/607

Answer 2

我遇到了同样的问题。您需要宣传 Kafka 代理的主机名/IP 以便可以从 Kafka Producer pc 访问。

 kafka-server-start.sh config/server.properties --override  advertised.listeners=PLAINTEXT://<accessible-hostname>:9092

Answer 3

同样的问题，你会发现有些端口可以工作，有些则不行。

只需将其更改为 19092 即可，因为使用 15672 的 rabbitMQ 效果很好，我想原因是 OSX 占用了一些端口