Howdy. I've been using the ProcessorTopologyTestDriver for testing my Kafka Streams topologies, and it's worked great. But now I'd like to test the punctuation functionality in my topology, and I don't see anything in ProcessorTopologyTestDriver that allows for that. The KStreamTestDriver has a punctuate() method available, but it looks to be for the older (pre-1.0.0) punctuation functionality. So I modified the ProcessorTopologyTestDriver to also call:
task.maybePunctuateStreamTime(); task.maybePunctuateSystemTime(); within ProcessorTopologyTestDriver's process() method, right after task.commit(); Is there a better way to test punctuation functionality?
