Use in-memory value of source_timestamp to make sure river items are processed only once
Use new '_seq' field instead of source timestamp.