就是搞不懂为啥一直报超时信息 端口防火墙是放开的 集群配置监听 是这种方式 listeners=PLAINTEXT://vm144:9092 producer端也是以vm144:9092的方式访问 telnet vm144:9092是通的
老师 同步的方式 异常信息
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.(KafkaProducer.java:1150)
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:846)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:784)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:671)
at org.cytec.damon.analysis.dataEncryption.EncryptionApp.main(EncryptionApp.java:29)
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
你这都是debug日志。
你的生产者用同步的发送试试。看看报啥错。
producer.send(record).get();