我刚刚安装了Cloudera QuickStart VM并添加了Kafka服务 . 添加Kafka服务后，我可以轻松创建 生产环境 者/消费者，一切都按预期工作 . 几天后重新启动VM，我收到以下异常：
线程“main”中的异常java.util.concurrent.ExecutionException：org.apache.kafka.common.errors.TimeoutException：60000 ms后无法更新元数据 . org.apache.kafka.clients.producer.KafkaProducer $ FutureFailure . （KafkaProducer.java:1124）位于org.apache.kafka的org.apache.kafka.clients.producer.KafkaProducer.doSend（KafkaProducer.java:823） . clients.producer.KafkaProducer.send（KafkaProducer.java:760）atg.apache.kafka.clients.producer.KafkaProducer.send（KafkaProducer.java:648）at test.kafka.KafkaProducerExample.runProducer（KafkaProducerExample.java:37） at test.kafka.KafkaProducerExample.main（KafkaProducerExample.java:54）引起：org.apache.kafka.common.errors.TimeoutException：60000毫秒后无法更新元数据 .
我试图用telnet连接到端口9092并且它可以正常工作 . 我可以从QuickStart VM内部发送消息 . 有什么建议 ？
1 回答
您可以尝试删除zookeeper日志以及您的kafka经纪人日志，然后尝试运行您认为它将起作用 . 它没有用，因为它正在获取旧日志 . 您可以从zookeeper.properties和server.properties更改日志目录路径 .