Expose a wrapper Record type which exposes data as byte[] instead

[theburningmonk]

Otherwise, to enable safe retry the consumer will need to know to not close the stream and to set the position in the stream to 0 on every attempt. It's much clearer if data is a byte array instead.