Function mz_testdrive::action::kafka::ingest::make_transcoder

async fn make_transcoder(
    state: &State,
    format: Format,
    ccsr_subject: String
) -> Result<Transcoder, Error>