public Fetch<K, V> collectFetch() {
        return fetchCollector.collectFetch(fetchBuffer);
    }
Set up a fetch request for any node that we have assigned partitions for which doesn't already have
an in-flight fetch or pending fetch data.
@return number of fetches sent
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java