Create a new stream source

Create a new source for ingesting events into the stream.