Function mz_storage_client::sink::publish_kafka_schema

pub async fn publish_kafka_schema(
    ccsr: Client,
    subject: String,
    schema: String,
    schema_type: SchemaType,
    compatibility_level: Option<CompatibilityLevel>,
) -> Result<i32, Error>

Publish a schema for a given subject, and set compatibility levels for the schema if applicable.

TODO(benesch): do we need to delete the Kafka topic if publishing the schema fails?