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

@param topic to be requested.
@return the future of the metadata request.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java