[streaming] Source parallelism + connector rework