kafka-InterBrokerSendThread.adoc

InterBrokerSendThread

InterBrokerSendThread is the extension of the ShutdownableThread contract for inter-broker send threads with a non-blocking NetworkClient that doWork.

Note	TransactionMarkerChannelManager is the only available implementation of the InterBrokerSendThread Contract in Apache Kafka.

doWork Method

doWork(): Unit

Note	doWork is a part of ShutdownableThread Contract.

doWork…​FIXME

sendRequests Internal Method

sendRequests(now: Long): Long

sendRequests…​FIXME

Note	sendRequests is used exclusively when InterBrokerSendThread is requested to doWork.

completeWithDisconnect Method

completeWithDisconnect(
  request: ClientRequest,
  now: Long,
  authenticationException: AuthenticationException): Unit

completeWithDisconnect…​FIXME

Note	completeWithDisconnect is used when InterBrokerSendThread is requested to checkDisconnects and failExpiredRequests (when InterBrokerSendThread is requested to doWork).

checkDisconnects Internal Method

checkDisconnects(now: Long): Unit

checkDisconnects…​FIXME

Note	checkDisconnects is used exclusively when InterBrokerSendThread is requested to doWork.

failExpiredRequests Internal Method

failExpiredRequests(now: Long): Unit

failExpiredRequests…​FIXME

Note	failExpiredRequests is used exclusively when InterBrokerSendThread is requested to doWork.

Creating InterBrokerSendThread Instance

InterBrokerSendThread takes the following to be created:

• Name

• NetworkClient

• Time

• isInterruptible flag (default: true)

InterBrokerSendThread initializes the internal registries and counters.