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.

Message version define which format of messages is using in this particular Produce/Response MessageV0 and MessageV1 indicate usage of MessageSet MessageV3 indicate usage of RecordBatch See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Messagesets.