OffsetCommitRequest build(short version)OffsetCommitRequest
OffsetCommitRequest is a concrete AbstractRequest with OffsetCommit API key and the following:
OffsetCommitRequest is used exclusively when ConsumerCoordinator is requested to send an OffsetCommitRequest to the group coordinator (a Kafka broker).
OffsetCommitRequest is created when:
-
AbstractRequestis requested to parse a request (with the OffsetCommit API key) -
OffsetCommitRequestis requested to parse a byte buffer -
OffsetCommitRequest.Builderis requested to build an OffsetCommitRequest
OffsetCommitRequest.Builder Factory Object
OffsetCommitRequest.Builder is a concrete AbstractRequest.Builder factory object that can build an OffsetCommitRequest.
Creating OffsetCommitRequest from Byte Buffer — parse Factory Method
OffsetCommitRequest parse(ByteBuffer buffer, short version)parse…FIXME
|
Note
|
parse is used when…FIXME
|
getErrorResponse Method
AbstractResponse getErrorResponse(int throttleTimeMs, Throwable e)|
Note
|
getErrorResponse is part of the AbstractRequest Contract to create a AbstractResponse for a failure.
|
getErrorResponse…FIXME