MessageBlock represents a part of request with message.

MessageSet is a replacement for RecordBatch in older versions.

Message is a kafka message type.

RecordBatch are records from one kafka request.

Record is kafka record type.

GroupMessage is an extension of the Message interface implemented by some request types to inform the program that they should be routed to a group coordinator.

Merger is an interface implemented by messages which can merge multiple results into one response.

Message is an interface implemented by all request and response types of the kafka protocol.

PreparedMessage is an extension of the Message interface implemented by some request types which may need to run some pre-processing on their state before being sent.