首先得明确你遇到的核心问题：Failed to update metadata after 60000ms这个异常，和你配置的retries重试逻辑不是一回事儿。

你的retries=3是用来重试消息发送阶段的可恢复错误（比如网络抖动、Leader节点临时不可用），但这个超时异常是因为Producer连不上Broker，根本拿不到集群的元数据（比如主题分区、Leader节点信息这些关键数据）——没有元数据，Producer连往哪发消息都不知道，自然没法触发后续的消息发送重试。

默认情况下，Producer在元数据请求超时后会直接抛出异常，不会自动持续重试获取元数据，所以就算你之后重启了Broker，它也不会主动去重试。

具体解决步骤 #

1. 补充元数据相关的重试配置

给你的Producer添加几个和元数据刷新、重连相关的配置，让它在Broker不可用时更积极地尝试恢复连接：

// 缩短元数据过期时间，让Producer更频繁尝试刷新元数据（默认5分钟，改成30秒）
props.put("metadata.max.age.ms", "30000");
// 重连Broker的初始间隔（和你的重试退避保持一致）
props.put("reconnect.backoff.ms", "1000");
// 重连的最大间隔时间，避免无限等待
props.put("reconnect.backoff.max.ms", "5000");

2. 在代码中捕获异常并手动重试发送

即使调整了配置，极端情况下还是可能触发超时异常，这时候需要在业务代码里主动捕获这类异常，实现自定义的重试逻辑（比如指数退避重试）：

Producer<String, String> producer = new KafkaProducer<>(props);
String targetTopic = "your-target-topic";
ProducerRecord<String, String> record = new ProducerRecord<>(targetTopic, "test-key", "test-value");

int retryTimes = 0;
boolean sendSuccess = false;
final int MAX_RETRY = 5; // 可以根据需求调整最大重试次数

while (!sendSuccess && retryTimes <= MAX_RETRY) {
    try {
        // 同步发送示例，异步发送可以在Callback里处理重试
        producer.send(record).get();
        sendSuccess = true;
        System.out.println("消息发送成功");
    } catch (TimeoutException e) {
        retryTimes++;
        System.out.printf("元数据获取超时，正在进行第%d次重试...%n", retryTimes);
        // 指数退避等待，避免频繁重试
        try {
            Thread.sleep(1000 * (long) Math.pow(2, retryTimes - 1));
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
            break;
        }
    } catch (Exception e) {
        // 处理其他不可恢复的异常
        System.err.println("发送遇到不可恢复错误：");
        e.printStackTrace();
        break;
    }
}

producer.close();

3. 确认幂等性配置的正确性

你当前的幂等性配置是没问题的：enable.idempotence=true、max.in.flight.requests.per.connection=1、acks=all，只要Broker重启后消息发送成功，不会出现重复消息的问题。

关键提醒 #

• request.timeout.ms是单个请求（包括元数据请求和消息发送请求）的超时时间，你设置的60000ms是合理的，不要改得太短，否则容易触发不必要的超时；
• 如果你用的是异步发送，一定要在Callback的onCompletion方法里处理异常和重试，不能只依赖Producer的自动重试；
• 当Broker重启后，Producer需要通过刷新元数据才能感知到Broker已恢复，缩短metadata.max.age.ms能让这个过程更快。

这样调整后，下次遇到Broker临时关闭再重启的情况，Producer就能自动恢复并把消息成功发送到主题了。

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