先明确下你的问题场景：

在使用Spring Boot 2.0发送Kafka消息时遇到异常：仅配置单个bootstrap-servers时发送成功，但配置集群时无法发送；使用Callable调用时出现如下错误信息：

java.util.concurrent.ExecutionException: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms

我之前处理过类似的问题，给你梳理几个最可能的原因和对应的解决步骤：

1. 先排查集群节点的网络连通性 #

这是最基础但容易忽略的点：确保应用服务器能访问到所有Kafka集群节点的端口（默认是9092，如果你改了端口就用自定义的）。

• 测试方式：在应用所在服务器上，用telnet <kafka-node-ip> <port>或者nc -zv <kafka-node-ip> <port>逐个验证每个节点的连通性。如果有某台节点连不通，那大概率是防火墙或者网络路由的问题，先把这个搞定。

2. 检查Bootstrap Servers的配置格式 #

确认你的application.yml或application.properties里的配置有没有格式错误：

• 正确的集群配置格式是逗号分隔，逗号前后不要加空格：

  spring.kafka.bootstrap-servers=kafka-node1:9092,kafka-node2:9092,kafka-node3:9092
  

• 常见错误：逗号后加了空格、节点IP/域名写错、端口号填错，这些都会导致Producer无法正确识别集群节点。

3. Kafka Broker的Advertised Listener配置错误（最常见的坑） #

这个是很多人踩过的坑：Kafka Producer拿到集群元数据后，会用Broker配置的advertised.listeners地址来建立实际连接。如果这个地址是集群内部的内网IP，但你的应用在外部网络，就会出现“能连到bootstrap节点，但获取元数据后无法连接其他节点”的情况。

• 检查Kafka Broker的server.properties配置：

  # 确保advertised.listeners配置的是应用能访问到的地址（公网IP/可解析的域名）
  advertised.listeners=PLAINTEXT://<公网IP或域名>:9092
  # 如果集群需要同时对内网和外网提供服务，可以配置多个listener
  listeners=PLAINTEXT://0.0.0.0:9092,EXTERNAL://0.0.0.0:9093
  advertised.listeners=PLAINTEXT://内网IP:9092,EXTERNAL://公网IP:9093
  # 记得对应配置协议映射
  listener.security.protocol.map=PLAINTEXT:PLAINTEXT,EXTERNAL:PLAINTEXT
  

• 对应的，应用配置里要使用外部listener的端口：spring.kafka.bootstrap-servers=公网IP1:9093,公网IP2:9093

4. 调整Producer的超时参数 #

Spring Boot 2.0默认的元数据更新超时是60秒，但如果你的网络环境较差或者集群节点较多，可以适当调整参数来适配：

# 调整元数据更新的最大间隔（比如改成30秒）
spring.kafka.producer.properties.metadata.max.age.ms=30000
# 缩短请求超时时间，避免长时间等待
spring.kafka.producer.properties.request.timeout.ms=15000
# 增加重试次数，提升容错性
spring.kafka.producer.properties.retries=3

5. Callable异步调用的上下文问题 #

使用Callable时，要确保Kafka相关的Bean能在异步线程中正常获取：

• 不要在Callable内部手动创建KafkaProducer，直接注入Spring管理的KafkaTemplate即可，它本身是线程安全的。
• 如果用了@Async或者自定义线程池，检查线程池是否配置了上下文传递（比如使用TaskDecorator来传递Spring上下文），避免异步线程无法获取到Kafka的配置信息。

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