AdminClientRunnable

AdminClientRunnable is a java.lang.Runnable that is used exclusively by KafkaAdminClient for…FIXME

Note	`AdminClientRunnable` is an internal part of and with full access to the internals of KafkaAdminClient (`private final class`).

Tip	`AdminClientRunnable` uses the org.apache.kafka.clients.admin.KafkaAdminClient logger so you should configure it properly to see what happens inside.

long sendEligibleCalls(long now)

sendEligibleCalls…FIXME

Note	`sendEligibleCalls` is used exclusively when `AdminClientRunnable` is requested to run.

void run()

Note	`run` is a part of java.lang.Runnable that is executed when the thread is started.

run…FIXME

void timeoutCallsInFlight(TimeoutProcessor processor)

timeoutCallsInFlight…FIXME

Note	`timeoutCallsInFlight` is used when…FIXME

void handleResponses(long now, List<ClientResponse> responses)

handleResponses…FIXME

Note	`handleResponses` is used when…FIXME

void call(
  Call call,
  long now)

call…FIXME

Note	`call` is used when…FIXME

void enqueue(
  Call call,
  long now)

enqueue prints out the following DEBUG message to the logs:

Queueing [call] with a timeout [timeout] ms from now.

enqueue…FIXME

Note	`enqueue` is used when…FIXME

results matching ""