Adding these lines at
(and replacing line 495) adds the custom metadata to the RecordBatch from the record batches message.
customMeta, err := metadataFromFB(msg)
if err != nil {
panic(err)
}
newSchema := arrow.NewSchema(schema.Fields(), &customMeta)
return array.NewRecordBatch(newSchema, cols, rows)