apache-spark - 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
}

“Kafka Exception java.util.concurrent.ExecutionException：org.apache.kafka.common.errors.TimeoutException：等待节点分配超时。调用：listTopics”