diff --git a/streams/src/test/java/org/apache/kafka/test/ProcessorTopologyTestDriver.java b/streams/src/test/java/org/apache/kafka/test/ProcessorTopologyTestDriver.java
index 88b7a54748885..2f5f653685c1e 100644
--- a/streams/src/test/java/org/apache/kafka/test/ProcessorTopologyTestDriver.java
+++ b/streams/src/test/java/org/apache/kafka/test/ProcessorTopologyTestDriver.java
@@ -199,6 +199,16 @@ public <K, V> void process(String topicName, K key, V value, Serializer<K> keySe
         process(topicName, keySerializer.serialize(topicName, key), valueSerializer.serialize(topicName, value));
     }
 
+    /**
+     * Possibly trigger registered punctuation functions if current time has reached the next defined timestamp for each of the
+     * processors.
+     *
+     * @param timestamp the current timestamp
+     */
+    public void maybePunctuate(long timestamp) {
+        task.maybePunctuate(timestamp);
+    }
+
     /**
      * Read the next record from the given topic. These records were output by the topology during the previous calls to
      * {@link #process(String, byte[], byte[])}.