# Functions
NewCorrelationCache returns a new correlation cache.
ReadRequest will read a Kafka request from an io.Reader and return the message or an error.
ReadResponse will read a Kafka response from an io.Reader and return the message or an error.
# Variables
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
List of possible Kafka error codes Reference: https://kafka.apache.org/protocol#protocol_error_codes.
RequestLifetime specifies the maximum time a request can stay in the correlation cache without getting correlated.
# Structs
CorrelationCache is a cache used to correlate requests with responses
It consists of two main functions:
cache.HandleRequest(request)
Must be called when a request is forwarded to the broker, will keep track of the request and rewrite the correlation ID inside of the request to a sequence number.
RequestMessage represents a Kafka request message.
ResponseMessage represents a Kafka response message.
# Type aliases
CorrelationID represents the correlation id as defined in the Kafka protocol specification.
FinishFunc is the function called when a request has been correlated with its response.