Skip to main content

round_trip

Function round_trip 

Source
pub async fn round_trip(
    endpoint: &Endpoint,
    topic: &str,
    partition: i32,
) -> Result<i64, String>
Expand description

Produce one record to topic-partition with acks=all, then read it back at the offset it was acknowledged at, and return that offset.

This is what “serving” means after a restore: a client of the restored cluster, authenticated as an ordinary principal, can write and then read.

§Errors

Returns why the write or the read failed, or that the record did not come back within a minute.