@Override
                    public void onSuccess(ClientResponse response, RequestFuture<ListOffsetResult> future) {
                        ListOffsetsResponse lor = (ListOffsetsResponse) response.responseBody();
                        log.trace("Received ListOffsetResponse {} from broker {}", lor, node);
                        handleListOffsetResponse(lor, future);
                    }
Send the ListOffsetRequest to a specific broker for the partitions and target timestamps.

@param node               The node to send the ListOffsetRequest to.
@param timestampsToSearch The mapping from partitions to the target timestamps.
@param requireTimestamp   True if we require a timestamp in the response.
@return A response which can be polled to obtain the corresponding timestamps and offsets.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java