I am afraid, that atm there is not good support for this... :( However, we plan to release official test utilities soon (planned for v1.1) that should contain proper support for punctuations.
So stay tuned. -Matthias On 12/15/17 7:31 AM, Tom Wessels wrote: > 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? >
signature.asc
Description: OpenPGP digital signature
