prefix is '{"type":"RECORD","record":{"namespace":"...","stream":"...","data":'
suffix is ',"emitted_at":...}}'