Skip to main content

read_all

krabka_replicator::admin_util

Function read_all 

Source 
pub async fn read_all(
    bootstrap: &str,
    topic: &str,
    security: Option<ClientSecurity>,
) -> Result<Vec<RawRecord>, String>
Expand description

ยงErrors

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