mz_kafka_util::admin

Function ensure_topic_config

Source 
pub async fn ensure_topic_config<'a, C>(
    client: &'a AdminClient<C>,
    admin_opts: &AdminOptions,
    new_topic: &'a NewTopic<'a>,
    expect: EnsureTopicConfig,
) -> Result<bool>
where
    C: ClientContext,
Expand description

Expect the current configuration for a particular topic to match a provided set of values. If there are other configs set, we will ignore them.

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.