use sourcePartition as streams key