kafka-TransactionMarkerChannelManager.adoc

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).