运行Kafka Java生产者代码遇超时错误：Failed to update metadata求助

我之前调试Kafka生产者的时候也踩过这个坑，这个错误本质是生产者花了60秒都没法从Kafka集群拿到元数据（比如topic的分区信息、broker地址），大概率是网络连接或者配置出了问题，给你几个排查和修复的方向：

问题还原 #

我正在运行一段Kafka Java生产者代码，但遇到如下错误：org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms。以下是我的生产者类代码片段：

import java.util.List;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.p...

排查与修复方案 #

• 检查Kafka集群连接配置是否正确
  确保你在生产者Properties里配置的bootstrap.servers是准确的，要填写集群内可用的broker地址和端口（比如localhost:9092或者xxx.xxx.xxx.xxx:9092,yyy.yyy.yyy.yyy:9092）。很多时候就是这里写错了，直接导致连不上broker。

• 验证网络连通性
  运行生产者的机器能不能ping通Kafka broker所在机器？如果是远程集群，还要检查防火墙是否开放了Kafka的端口（默认9092，自定义端口的话对应调整）。可以用telnet <broker-ip> <port>或者nc -zv <broker-ip> <port>命令测试端口是否能正常打通。

• 检查topic状态与权限
  如果你要发送的topic还未创建，且生产者配置里auto.create.topics.enable设为false，生产者无法自动创建topic就会拿不到元数据。要么手动在Kafka集群创建topic（执行kafka-topics.sh --create --topic your-topic --bootstrap-server <broker-addr> --partitions 3 --replication-factor 1），要么把auto.create.topics.enable临时设为true（生产环境不推荐开启这个配置）。

• 调整元数据相关超时配置（临时 workaround）
  如果你的网络环境确实存在延迟，可以尝试调大metadata.max.age.ms和request.timeout.ms配置，比如把request.timeout.ms从默认的30000改成60000以上，但这只是临时缓解，核心还是要解决底层的连接问题。

• 确认Kafka集群状态
  检查你的Kafka broker是否正常运行，有没有出现宕机、集群选举失败等情况。可以用kafka-topics.sh --list --bootstrap-server <broker-addr>命令测试能否正常列出topic，以此验证集群状态。

如果能贴出完整的生产者配置代码，就能更精准地定位问题——比如是否配置了错误的安全参数（如SASL/SSL），或者其他影响连接的特殊配置。

内容的提问来源于stack exchange，提问作者Shashank S