synchronized int getCurrIteration() {
            return currIteration;
        }
A class that periodically produces records in a separate thread
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java