Skip to main content

fetch_partition_with_isolation_progress

Function fetch_partition_with_isolation_progress 

Source
pub async fn fetch_partition_with_isolation_progress(
    conn: &Connection,
    fetch: IsolatedFetch<'_>,
) -> Result<FetchPartitionResult, ClientError>
Expand description

Fetch a partition with isolation and return both visible records and cursor progress across filtered transactional and control batches.

In READ_COMMITTED mode this function applies the response’s aborted_transactions metadata client-side, because Krabka brokers return the underlying record batches verbatim.

§Errors

Returns ClientError when the fetch request fails or the broker response is malformed.