ComputeCrc returns crc32 hash for given message content.

ConfigureParser configures the parser.

ReadReq returns request kind ID and byte representation of the whole message in wire protocol format.

ReadResp returns message correlation ID and byte representation of the whole message in wire protocol that is returned when reading from given stream, including 4 bytes of message size itself.

receive the earliest available offset.

receive the latest offset (i.e.

Server will block until the message is committed by all in sync replicas before sending a response.

Server will wait the data is written to the local log before sending a response.

Server will not send any response.

Message represents single entity of message set.

ParserConfig is optional configuration for the parser.