AbstractRequestResponse
is the abstraction of messages exchanged between Kafka clients and brokers.
Note
|
AbstractRequestResponse is a Java abstract class and cannot be created directly. It is created indirectly for the concrete AbstractRequestResponses.
|
AbstractRequestResponse
defines the single serialize
static method.
ByteBuffer serialize(Struct headerStruct, Struct bodyStruct)
serialize
simply allocates a new java.nio.ByteBuffer for the given header and body structs followed by writing them out to the buffer (and rewinding the buffer).
serialize
is used when AbstractRequest and AbstractResponse are requested to serialize.
AbstractRequestResponse | Description |
---|---|
RequestHeader |
|
ResponseHeader |