mz_kafka_util::admin

Function alter_topic_config

Source 
pub async fn alter_topic_config<'a, C>(
    client: &'a AdminClient<C>,
    admin_opts: &AdminOptions,
    topic_name: &str,
    new_config: impl IntoIterator<Item = (&str, &str)>,
) -> Result<()>
where
    C: ClientContext,
Expand description

Alter the current configuration for a particular topic.

Materialize may not have permission to alter configs for the topic, so callers of this method should “fail open” if the configs are not available.