protected FetchSessionHandler sessionHandler(int node) {
        return sessionHandlers.get(node);
    }
Create fetch requests for all nodes for which we have assigned partitions
that have no existing requests in flight.
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java