private void handleListOffsetResponse(ListOffsetsResponse listOffsetsResponse,
                                          RequestFuture<ListOffsetResult> future) {
        try {
            ListOffsetResult result = offsetFetcherUtils.handleListOffsetResponse(listOffsetsResponse);
            future.complete(result);
        } catch (RuntimeException e) {
            future.raise(e);
        }
    }
Callback for the response of the list offset call above.

@param listOffsetsResponse The response from the server.
@param future              The future to be completed when the response returns. Note that any partition-level errors will
                           generally fail the entire future result. The one exception is UNSUPPORTED_FOR_MESSAGE_FORMAT,
                           which indicates that the broker does not support the v1 message format. Partitions with this
                           particular error are simply left out of the future map. Note that the corresponding timestamp
                           value of each partition may be null only for v0. In v1 and later the ListOffset API would not
                           return a null timestamp (-1 is returned instead when necessary).
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java