Generating data stream for testing

[Thomas Weise]

Hi,

I'm looking for the suitable starting point to create an unbounded source
for testing of a pipeline. The source should generate data (let's say
KV<String, Integer>), but can also inject watermarks.

I see couple implementations like TestCountingSource used for runner
testing, is the starting point for users UnboundedSource?

Thanks,
Thomas