AbstractRequest Contract

AbstractRequest is the extension of the AbstractRequestResponse contract for message requests.

AbstractRequest takes the following to be created:

  • ApiKeys

  • Version

Note
AbstractRequest is a Java abstract class and cannot be created directly. It is created indirectly for the concrete AbstractRequests.
Table 1. AbstractRequest Contract
Method Description

getErrorResponse

AbstractResponse getErrorResponse(
  int throttleTimeMs,
  Throwable e)

Used when…​FIXME

toStruct

Struct toStruct()

Used when…​FIXME

Table 2. AbstractRequests
AbstractRequest Description

AddOffsetsToTxnRequest

AddPartitionsToTxnRequest

AlterConfigsRequest

AlterReplicaLogDirsRequest

ApiVersionsRequest

ControlledShutdownRequest

CreateAclsRequest

CreateDelegationTokenRequest

CreatePartitionsRequest

CreateTopicsRequest

DeleteAclsRequest

DeleteGroupsRequest

DeleteRecordsRequest

DeleteTopicsRequest

DescribeAclsRequest

DescribeConfigsRequest

DescribeDelegationTokenRequest

DescribeGroupsRequest

DescribeLogDirsRequest

EndTxnRequest

ExpireDelegationTokenRequest

FetchRequest

FindCoordinatorRequest

HeartbeatRequest

InitProducerIdRequest

JoinGroupRequest

LeaderAndIsrRequest

LeaveGroupRequest

ListGroupsRequest

ListOffsetRequest

MetadataRequest

OffsetCommitRequest

OffsetFetchRequest

OffsetsForLeaderEpochRequest

ProduceRequest

RenewDelegationTokenRequest

SaslAuthenticateRequest

SaslHandshakeRequest

StopReplicaRequest

SyncGroupRequest

TxnOffsetCommitRequest

UpdateMetadataRequest

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.

results matching ""

    No results matching ""