Spring-Kafka 1.3.0：事务生产者连接宕机服务器无限等待问题求助

你遇到的这个问题，核心是事务型生产者初始化时，获取集群元数据和事务协调器的过程没有被正确的超时配置限制，导致bootstrap server宕机时出现无限等待的情况。咱们结合spring-kafka 1.3.0.RELEASE的特性来拆解：

为什么会无限等待？ #

当你设置了transactionIdPrefix后，DefaultKafkaProducerFactory.createProducer()会触发以下关键操作：

1. 生成唯一的事务ID
2. 创建底层的KafkaProducer实例
3. 调用initTransactions()方法初始化事务

这个初始化过程需要连接到Kafka集群获取元数据（包括事务协调器的地址），而spring-kafka 1.3.x对应的kafka-clients 0.11.x版本中，默认的元数据获取超时是60秒，且如果你的配置没有覆盖这个值，加上max.block.ms可能没有完全覆盖初始化阶段的所有阻塞场景，就会出现看似“无限等待”的情况。

你的配置遗漏了什么？ #

你已经设置了MAX_BLOCK_MS_CONFIG、REQUEST_TIMEOUT_MS_CONFIG，但还需要添加元数据获取超时的配置，来限制初始化阶段的阻塞时间。

修正后的配置方案 #

修改你的producerConfigs()方法，添加metadata.fetch.timeout.ms配置：

private static Map<String, Object> producerConfigs() { 
    final Map<String, Object> props = new HashMap<>(); 
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.56.1:9092"); 
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer"); 
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer"); 
    props.put(ProducerConfig.RETRIES_CONFIG, 1); 
    props.put(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, 1); 
    props.put(ProducerConfig.TRANSACTION_TIMEOUT_CONFIG, 1000); 
    props.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 1000); 
    props.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 1000); 
    // 添加元数据获取超时，限制初始化阶段的阻塞时间
    props.put("metadata.fetch.timeout.ms", 1000);
    return props; 
}

额外注意事项 #

1. 异常处理：添加超时配置后，当bootstrap不可用时，createProducer()会在1秒后抛出TimeoutException，你需要在代码中捕获这个异常，避免程序挂起：

try {
    final Producer<Object, Object> producer = producerFactory.createProducer(); 
    System.out.println("Created producer:" + producer); 
} catch (TimeoutException e) {
    System.err.println("Failed to create producer: bootstrap server unavailable");
    // 这里可以添加重试或退出逻辑
}

2. 版本建议：spring-kafka 1.3.0.RELEASE是比较老旧的版本（基于kafka-clients 0.11.x），后续的2.x+版本对事务生产者的超时逻辑做了更完善的优化，建议升级到较新的稳定版本，比如2.8.x或更高，能避免很多这类兼容性问题。

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