THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
{ size: int32 // the size of this request request_type_id: int16 // the request id version_id: int16 // the version of this request correlation_id: int32 // an id set by the client that will be returned untouched in the response client_id: string // an optional non-machine-specific identifier for this client required_acks: int8 // the number of acknowledgements required from the brokers before a response can be made ack_timeout: int32 // the time in ms to wait for acknowledgement from replicas data: null // no need data for the consult request } |
...
Code Block |
---|
{ size: int32 // the size of this request correlation_id: int16 // the request id version_id: int16 // the version of this request error: int16 // an id set by the client that will be returned untouched in the response data: {coordinatorId: int16, [<broker_struct>]} // the actual data requested (in the same format as defined for the produce request) } broker_struct => { idcreatorId: creatorId id: host: port: } |
Coordinator Request Format :
...