public ProcessId poll(final TaskId task) {
        return poll(task, client -> true);
    }
@return the next least loaded client that satisfies the given criteria, or null if none do
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java