...
And the response:
Code Block |
---|
Response => VersionIdResponseVersion CorrelationId ResponseMessage ResponseVersion => int16 CorrelationId => int32 ResponseMessage => MetadataResponse | ProduceResponse | FetchResponse | OffsetResponse |
Field | Description |
---|---|
ResponseVersion | Indicates the version of the version of the response object. |
CorrelationId | The server passes back whatever integer the client supplied as the correlation in the request. |
Message sets
One structure common to both the produce and fetch requests is the message set format. A message in kafka is a key-value pair with a small amount of associated metadata. A message set is just a sequence of messages with offset and size information. This format happens to be used both for the on-disk storage on the broker and the on-the-wire format.
...