Function read_all_with_policy 

pub async fn read_all_with_policy(
    bootstrap: &str,
    topic: &str,
    security: Option<ClientSecurity>,
    client_resource_policy: ClientResourcePolicy,
) -> Result<Vec<RawRecord>, String>

Drain a topic using the deployment’s client resource policy.

Errors

Returns an error when configuration is invalid, protocol encoding fails, the broker rejects the request, or transport I/O fails.