Major Description
Create the downstream wiring with In Memory System with stream of collection, this api should provide end points to initialize a stream from an input collection to in memory file system and also have utility to access the state of this stream at any given time
Link to SEP:
Samza Integration Test Framework