Function list_topics

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

List the topics for the DS Event Stream.

Arguments

• bootstrap_servers - The bootstrap servers to list the topics for.
• credentials - The credentials for the DS Event Stream.

Returns

• Vec<String> - The topic names for the DS Event Stream.

Errors

• UtilsError::Kafka - If the Kafka client fails to fetch metadata.
• UtilsError::TopicsNotFound - If the topics are not found.