kafka-clients-ClientRequest.adoc

ClientRequest

ClientRequest is…​FIXME

ClientRequest is created exclusively when NetworkClient is requested to create one.

ClientRequest uses the client ID when requested to makeHeader.

Creating ClientRequest Instance

ClientRequest takes the following when created:

• Destination

• AbstractRequest.Builder

• Correlation ID

• Client ID

• createdTimeMs

• expectResponse flag

• requestTimeoutMs

• RequestCompletionHandler

ClientRequest initializes the internal registries and counters.

Creating RequestHeader — makeHeader Method

RequestHeader makeHeader(short version)

makeHeader creates a RequestHeader (with the client and the correlation IDs)

Note	makeHeader is used when: InterBrokerSendThread is requested to completeWithDisconnect NetworkClient is requested to doSend ConsumerNetworkClient is requested to checkDisconnects