Each key needs to store the size of the stream and update it if appended
Each key needs to store the size of the stream and update it if appended