public CompletableFuture<Map<String, List<PartitionInfo>>> requestAllTopicsMetadata(final long deadlineMs) {
        TopicMetadataRequestState newRequest = new TopicMetadataRequestState(
                logContext,
                deadlineMs,
                retryBackoffMs,
                retryBackoffMaxMs);
        inflightRequests.add(newRequest);
        return newRequest.future;
    }
Return the future of the metadata request.

@return the future of the metadata request.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java