public void resumePollingForPartitionsWithAvailableSpace() {
        for (final Task t: tasks.activeTasks()) {
            t.resumePollingForPartitionsWithAvailableSpace();
        }
    }
Resumes polling in the main consumer for all partitions for which
the corresponding record queues have capacity (again).
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java