Skip to main content

fetch_error_response

Function fetch_error_response 

Source
pub fn fetch_error_response(
    request: &FetchRequest,
    version: i16,
    error_code: i16,
) -> FetchResponse
Expand description

Kafka’s FetchRequest.getErrorResponse: error_code and the session id of request at the top level.

Before v13 every requested partition also carries the code, as FetchResponse.partitionResponse builds it: an invalid high watermark and empty, non-null records.