When making the RecordProcessor cloneable we forgot the clone() method on the MemoryBufferRecorder; this causes the collected records to be shared between different endpoints.