Kafka Admin Client 为 ListTopic 提供超时错误

Question

您好，我正在尝试运行此代码 但它在另一个 EC2 Azkaban 实例中运行良好，但在另一个实例中没有给出以下错误。

private val adminprops = new Properties() 
adminprops.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,"Kafka Endpoint")
private val admin = AdminClient.create(adminprops)

def topicExist(topicName: String): Boolean = {
 val result = admin.listTopics.names.get.contains(topicName)
 result
}

“卡夫卡异常java.util.concurrent.ExecutionException： org.apache.kafka.common.errors.TimeoutException：等待节点超时 任务。调用：listTopics"

Answer 1

网络问题或设置问题。

1. 确保“bootstrap.servers”正确，正确的主机和端口。
2. 确保客户端和代理服务器之间的网络正常。

adminClient 的默认超时时间为 120000 毫秒（AdminClientConfig.REQUEST_TIMEOUT_MS_CONFIG）。通常，列表主题会立即返回。