fn create_admin_client(
bootstrap_servers: &str,
credentials: &ClientCredentials,
) -> Result<AdminClient<DefaultClientContext>>
Expand description
Create an admin client.
§Arguments
bootstrap_servers
- The bootstrap servers to create the admin client for.username
- The username for the DS Event Stream.password
- The password for the DS Event Stream.
§Returns
AdminClient<DefaultClientContext>
- The admin client.
§Errors
UtilsError::Kafka
- If the Kafka client fails to create.