Function sql::kafka_util::extract

fn extract(
    input: &mut BTreeMap<String, Value>, 
    configs: &[Config]
) -> Result<BTreeMap<String, String>, Error>