TransactionMarkerChannelManager

TransactionMarkerChannelManager is a InterBrokerSendThread that…FIXME

TransactionMarkerChannelManager uses the name TxnMarkerSenderThread-[brokerId].

TransactionMarkerChannelManager uses [Transaction Marker Channel Manager [brokerId]] as the logging prefix (aka logIdent).

TransactionMarkerChannelManager is created (using apply factory method) exclusively when TransactionCoordinator is created (for a KafkaServer).

Creating TransactionMarkerChannelManager Instance

TransactionMarkerChannelManager takes the following to be created:

KafkaConfig
MetadataCache
NetworkClient
TransactionStateManager
DelayedOperationPurgatory[DelayedTxnMarker]
Time

TransactionMarkerChannelManager initializes the internal registries and counters.

Creating TransactionMarkerChannelManager — `apply` Factory Method

apply(
  config: KafkaConfig,
  metrics: Metrics,
  metadataCache: MetadataCache,
  txnStateManager: TransactionStateManager,
  txnMarkerPurgatory: DelayedOperationPurgatory[DelayedTxnMarker],
  time: Time,
  logContext: LogContext): TransactionMarkerChannelManager

apply…FIXME

Note	`apply` is used exclusively when `TransactionCoordinator` is created (when `KafkaServer` is requested to start up).

TransactionMarkerChannelManager