mz_kafka_util::admin

Function get_topic_config

Source 
pub async fn get_topic_config<'a, C>(
    client: &'a AdminClient<C>,
    admin_opts: &AdminOptions,
    topic_name: &str,
) -> Result<Vec<ConfigEntry>>
where
    C: ClientContext,
Expand description

Get the current configuration for a particular topic.

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