升级kafka-clients至2.6.0后listTopics触发TimeoutException求助

我之前也碰到过类似的情况，从Kafka clients 2.5.x升级到2.6.0后，AdminClient调用listTopics频繁抛出TimeoutException，还附带The AdminClient thread has exited的错误提示。结合你的代码和报错信息，给你几个针对性的解决方案：

1. 修正AdminClient配置的参数类型 #

你代码里把超时参数设置成了字符串：

adminProperties.put(AdminClientConfig.DEFAULT_API_TIMEOUT_MS_CONFIG, "900000");

Kafka的AdminClient配置需要接收整数类型的超时值，字符串类型可能导致配置解析失效，进而使用默认的短超时时间。改成整数即可：

adminProperties.put(AdminClientConfig.DEFAULT_API_TIMEOUT_MS_CONFIG, 900000);

2. 确保AdminClient实例不被提前回收/关闭 #

报错里的The AdminClient thread has exited是关键提示——这说明在listTopics的Future完成前，AdminClient的线程已经被终止了。通常有两种情况：

• AdminClient实例被垃圾回收（比如没有保持强引用）
• 代码中提前调用了adminClient.close()

建议用try-with-resources来管理AdminClient的生命周期，确保在所有异步操作完成后再自动关闭：

try (AdminClient adminClient = KafkaAdminClient.create(adminProperties)) {
    ListTopicsResult listTopicsResult = adminClient.listTopics(new ListTopicsOptions().timeoutMs(900000));
    Collection<TopicListing> topicNames = listTopicsResult.listings().get(900, TimeUnit.SECONDS);
    // 正确判断主题是否存在（注意TopicListing是对象，要比较name()方法）
    boolean topicExists = topicNames.stream().anyMatch(topic -> topic.name().equals("myDataTopic"));
    System.out.println("Topic exists: " + topicExists);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
    e.printStackTrace();
}

3. 调整AdminClient的线程池与连接配置 #

Kafka 2.6.0对AdminClient的线程模型做了优化，默认配置可能不足以支撑某些场景。添加以下配置来增强稳定性：

// 连接空闲超时，避免连接被过早关闭
adminProperties.put(AdminClientConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG, 300000);
// 单个请求的超时时间
adminProperties.put(AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG, 30000);
// 元数据刷新间隔
adminProperties.put(AdminClientConfig.METADATA_MAX_AGE_CONFIG, 300000);
// 避免AdminClient线程过早闲置退出
adminProperties.put(AdminClientConfig.ADMIN_CLIENT_IDLE_TIMEOUT_MS_CONFIG, 60000);

4. 验证集群兼容性与网络连通性 #

• 确保Kafka Broker版本与client版本兼容：2.6.0的client连接2.5.x的Broker可能存在兼容性问题，建议保持client和Broker版本一致，或者参考官方兼容性矩阵确认。
• 用命令行工具验证连通性：执行kafka-topics.sh --list --bootstrap-server localhost:9092，如果能正常列出主题，说明网络和权限没有问题，问题集中在client代码配置。

5. 修正主题存在性判断逻辑 #

你原来的代码里topicNames.contains("myDataTopic")是错误的——topicNames是Collection<TopicListing>，不是字符串集合，直接用contains比较字符串永远返回false。改用流遍历比较主题名称：

boolean topicExists = topicNames.stream().anyMatch(topic -> topic.name().equals("myDataTopic"));

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