Hey all, Currently streaming topology tests use TestStreamEnvironment and static collections as sinks for assertion. I see that that the batch API tests use CollectionEnvironment for this purpose.
Is there any reason streaming do not have something like that? I think it would be more compact and safe to implement and use a similar environment in streaming too. If there is no objection, I'll open a JIRA ticket for this. Cheers, Gabor
