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

我是 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-ports

KAFKA 的版本是 2.12-2.0.0,我已经将以下 jars 添加到我的 Eclipse Classpath 中:


kafka-clients-2.0.0.jar

lz4-java-1.4.1.jar

slf4j-api-1.7.25.jar

snappy-java-1.1.7.1.jar

非常感谢您提前提供帮助:)


Regadrs,DIRSHAH。


一只甜甜圈
浏览 1016回答 3
3回答

慕丝7291255

此错误可能表明该主题不存在,因此您可能需要仔细检查您的 topicName = "Hello-Kafka"。虽然这不是一个深刻的答案,但它似乎是一个常见问题,另见https://github.com/dpkp/kafka-python/issues/607

红糖糍粑

我遇到了同样的问题。您需要宣传 Kafka 代理的主机名/IP 以便可以从 Kafka Producer pc 访问。&nbsp;kafka-server-start.sh&nbsp;config/server.properties&nbsp;--override&nbsp;&nbsp;advertised.listeners=PLAINTEXT://<accessible-hostname>:9092

呼啦一阵风

同样的问题,你会发现有些端口可以工作,有些则不行。只需将其更改为 19092 即可,因为使用 15672 的 rabbitMQ 效果很好,我想原因是 OSX 占用了一些端口
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java