Function mz_storage_client::sink::publish_kafka_schemas
source · pub async fn publish_kafka_schemas(
ccsr: Client,
topic: String,
key_schema: Option<String>,
key_schema_type: Option<SchemaType>,
value_schema: String,
value_schema_type: SchemaType,
key_compatibility_level: Option<CompatibilityLevel>,
value_compatibility_level: Option<CompatibilityLevel>
) -> Result<(Option<i32>, i32), Error>
Expand description
Publish value and optional key schemas for a given topic, and set compatibility levels for the schemas if applicable.
TODO(benesch): do we need to delete the Kafka topic if publishing the schema fails?