Module frame 

Kafka wire framing, and request and response correlation. This module has no schema knowledge.

Structs

CapturedFrame

One captured frame, emitted by the relay to the recorder spool.

Pending

Per-connection map from a correlation id to the (api_key, api_version) of the request that carried it. The relay uses the map to classify the responses.

RequestPrefix

Functions

parse_request_prefix

Parse the fixed request-header prefix that every request type has: api_key: i16, api_version: i16, correlation_id: i32.

read_correlation_id

Every response body starts with correlation_id: i32, before any tagged header. This is true for flexible and non-flexible responses alike.