[streaming] Added source record serialization tools