[streaming] Streaming API grouping rework to use batch api Keys
[squash] [streaming] Source rework wip
[squash] [streaming] Source rework wip2
[squash] [streaming] Source rework wip3
[streaming] Source rework wip3