Function get_topic

pub fn get_topic(
    bootstrap_servers: &str,
    credentials: &ClientCredentials,
    topic_name: &str,
) -> Result<String>

Get the name of a specific topic.

Arguments

• bootstrap_servers - The bootstrap servers to get the topic metadata for.
• credentials - The credentials for the DS Event Stream.
• topic_name - The name of the topic to get metadata for.

Returns

• String - The topic name if found.

Errors

• UtilsError::Kafka - If the Kafka client fails to fetch metadata.
• UtilsError::TopicNotFound - If the topic is not found.