Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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 :

...