diff --git a/schema/tuples.go b/schema/tuples.go
index 676636bad15cf638901e9618f15e633a704a1cdb..12979af5e40d69903c1632a9bac208bec41f8ca8 100644
--- a/schema/tuples.go
+++ b/schema/tuples.go
@@ -88,7 +88,7 @@ func unmarshalRecordRecursively(record []byte) (map[string]any, error) {
 		s = strings.TrimPrefix(s, "@cee:")
 		if strings.HasPrefix(s, "{") {
 			var m2 map[string]any
-			if err := json.Unmarshal([]byte(s[5:]), &m2); err == nil {
+			if err := json.NewDecoder(strings.NewReader(s)).Decode(&m2); err == nil {
 				m["message"] = m2
 			}
 		}