AbstractResponse getErrorResponse(
int throttleTimeMs,
Throwable e)
AbstractRequest Contract
AbstractRequest
is the extension of the AbstractRequestResponse contract for message requests.
AbstractRequest
takes the following to be created:
Note
|
AbstractRequest is a Java abstract class and cannot be created directly. It is created indirectly for the concrete AbstractRequests.
|
Method | Description |
---|---|
|
Used when…FIXME |
|
Used when…FIXME |
AbstractRequest | Description |
---|---|
Base of controller requests that KafkaController uses to propage broker and partition state changes to brokers |
|
AddOffsetsToTxnRequest |
|
AddPartitionsToTxnRequest |
|
AlterConfigsRequest |
|
AlterReplicaLogDirsRequest |
|
ApiVersionsRequest |
|
ControlledShutdownRequest |
|
CreateAclsRequest |
|
CreateDelegationTokenRequest |
|
CreatePartitionsRequest |
|
CreateTopicsRequest |
|
DeleteAclsRequest |
|
DeleteGroupsRequest |
|
DeleteRecordsRequest |
|
DeleteTopicsRequest |
|
DescribeAclsRequest |
|
DescribeDelegationTokenRequest |
|
DescribeGroupsRequest |
|
EndTxnRequest |
|
ExpireDelegationTokenRequest |
|
IncrementalAlterConfigsRequest |
|
InitProducerIdRequest |
|
LeaveGroupRequest |
|
ListGroupsRequest |
|
ListOffsetRequest |
|
OffsetFetchRequest |
|
OffsetsForLeaderEpochRequest |
|
ProduceRequest |
|
RenewDelegationTokenRequest |
|
SaslAuthenticateRequest |
|
SaslHandshakeRequest |
|
SyncGroupRequest |
|
TxnOffsetCommitRequest |
|
WriteTxnMarkersRequest |
Creating AbstractRequest For API Key — parseRequest
Factory Method
AbstractRequest parseRequest(
ApiKeys apiKey,
short apiVersion,
Struct struct)
parseRequest
simply creates a concrete AbstractRequest for the given ApiKeys
.
Note
|
parseRequest is used exclusively when RequestContext is requested to parse a request.
|