Hi, I have a streaming integration test with two operators. A source that emits records and watermarks, and a sink that collects the records. The topology runs in embedded mode and the results are collected in memory. Now, in addition to the records, I also want to verify that watermarks have been emitted. What's the recommended way of doing that?
Thanks
