kafka:60000毫秒后更新元数据失败

cgvd09ve  于 2021-06-06  发布在  Kafka
关注(0)|答案(3)|浏览(538)

我是新来Kafka,我知道这个问题已经被问了多次堆栈溢出,但没有一个解决方案对我有效,所以在这里,我尝试再次问同样的问题我的运气。我已经在centos7虚拟机上下载并安装了kfka。虚拟机在我的笔记本电脑上。当我从命令行运行kafka生产者和消费者时,它工作得很好。下一步,我想创建一个java生产者,但它总是超时,出现以下异常。

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.

生产者的java代码是:

package com.soft;
import java.util.Properties;
import java.util.concurrent.Future;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
public class SimpleProducer {
    public static void main(String[] args) throws Exception {
        try {
            String topicName = "Hello-Kafka";
            Properties props = new Properties();
            props.put("bootstrap.servers", "192.168.xxx.xxx:9092");
            props.put("acks", "all");
            props.put("retries", 1);
            props.put("batch.size", 16384);
            props.put("linger.ms", 1);
            props.put("buffer.memory", 33554432);
            props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
            Producer<String, String> producer = new KafkaProducer<String, String>(props);
            Future<RecordMetadata> f=producer.send(new ProducerRecord<String, String>(topicName, "Eclipse"));
            System.out.println("Message sent successfully");
            producer.close();
        } catch (Exception e) {
            System.out.println(e.getMessage());
        } 
            System.out.println("Successful");

    }
}

对于bootstrap.server,我甚至尝试了以下方法:
props.put(“bootstrap.servers”,“plaintext://192.168..:9092");
请注意,我正在笔记本电脑上执行eclipse的java代码,kafka安装在笔记本电脑的centos7vm上。192.168..是centos7虚拟机的ip地址。我注意到192.168.。:9092 无法从我的笔记本电脑访问(telnet 192.168.. 9092)。我将端口添加到防火墙,但仍然没有成功。

firewall-cmd --zone=public --add-port=9092/tcp --permanent
        firewall-cmd --reload
        firewall-cmd --list-ports

kafka的版本是2.12-2.0.0,我在eclipse类路径中添加了以下jar:
Kafka客户端-2.0.0.jar
lz4-java-1.4.1.jar
slf4j-api-1.7.25.jar
snappy-java-1.1.7.1.jar
非常感谢您的帮助:)
雷加德斯,迪尔沙。

guz6ccqo

guz6ccqo1#

此错误可能表示该主题不存在,因此您可能需要再次检查topicname=“hello kafka”。
虽然这并不是一个深刻的答案,但似乎是一个常见的问题,请参阅https://github.com/dpkp/kafka-python/issues/607

zd287kbt

zd287kbt2#

我也面临同样的问题。您需要公布kafka代理的主机名/ip,以便从kafka producer pc访问。

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

vom3gejh3#

同样的问题,你会发现有些端口可以工作,有些不能。
只要把它改成19092就行了,因为rabbitmq使用15672工作得很好,我猜原因是osx占用了一些端口

相关问题