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
