kamalcph commented on PR #20007: URL: https://github.com/apache/kafka/pull/20007#issuecomment-3026663544
@jiafu1115 Thanks for following up on this issue! We didn't face this issue as the `describeTopic` API now uses [handleDescribeTopicsByNamesWithDescribeTopicPartitionsApi](https://sourcegraph.com/github.com/apache/kafka/-/blob/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java?L2313-2315), and internally it sends `describeCluster` request to the [LeastLoadedBrokerOrActiveKController](https://sourcegraph.com/github.com/apache/kafka/-/blob/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java?L2465). So, if your controller queue is busy, then it cannot serve the `listNodes` request. Could you check why controller couldn't respond the request in 30 seconds? Previously, the describeTopic request sends the `METADATA` request to any of the LeastLoadedNode, so the operation was cheap and 2 mins is enough to ensure that the topic exists in the cluster. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
