KafkaClient¶

KafkaClient is an interface to NetworkClient.

Contract¶

inFlightRequestCount¶

int inFlightRequestCount()
int inFlightRequestCount(
  String nodeId)

Used when:

• ConsumerNetworkClient is requested to pendingRequestCount and poll
• Sender is requested to run
• SenderMetrics is requested for requests-in-flight performance metric

leastLoadedNode¶

Node leastLoadedNode(
  long now)

Used when:

• ConsumerNetworkClient is requested for the leastLoadedNode
• DefaultMetadataUpdater is requested to maybeUpdate
• KafkaAdminClient is used
• Sender is requested for the maybeSendAndPollTransactionalRequest

newClientRequest¶

ClientRequest newClientRequest(
  String nodeId,
  AbstractRequest.Builder<?> requestBuilder,
  long createdTimeMs,
  boolean expectResponse)
ClientRequest newClientRequest(
  String nodeId,
  AbstractRequest.Builder<?> requestBuilder,
  long createdTimeMs,
  boolean expectResponse,
  int requestTimeoutMs,
  RequestCompletionHandler callback)

Used when:

• AdminClientRunnable is requested to sendEligibleCalls
• ConsumerNetworkClient is requested to send
• NetworkClient is requested to newClientRequest, sendInternalMetadataRequest and handleInitiateApiVersionRequests
• RequestSendThread is requested to doWork
• Sender is requested to run
• KafkaServer is requested to controlledShutdown
• ReplicaFetcherBlockingSend is requested to sendRequest

poll¶

List<ClientResponse> poll(
  long timeout,
  long now)

Used when:

• FIXME

pollDelayMs¶

long pollDelayMs(
  Node node,
  long now)

Used when:

• FIXME

Is Node Ready and Connected¶

boolean ready(
  Node node,
  long now);

Used when:

• AdminClientRunnable is requested to sendEligibleCalls
• ConsumerNetworkClient is requested to tryConnect and trySend
• InterBrokerSendThread is requested to sendRequests
• NetworkClientUtils is requested to awaitReady
• Sender is requested to sendProducerData

send¶

void send(
  ClientRequest request,
  long now)

Used when:

• FIXME

wakeup¶

void wakeup()

Used when:

• FIXME

Implementations¶

• NetworkClient

Closeable¶

KafkaClient is a Closeable (Java).