Function mz_storage::source::kafka::construct_source_message

source ยท 
fn construct_source_message(
    msg: &BorrowedMessage<'_>,
    metadata_columns: &[KafkaMetadataKind],
) -> (Result<SourceMessage, KafkaHeaderParseError>, (PartitionId, MzOffset))