kafka-TransactionCoordinator.adoc

TransactionCoordinator

TransactionCoordinator is…​FIXME

TransactionCoordinator is created when…​FIXME

startup Method

startup

startup…​FIXME

Note	startup is used exclusively when KafkaServer is requested to start up.

Creating TransactionCoordinator Instance

TransactionCoordinator takes the following when created:

• Broker ID

• TransactionConfig

• Scheduler

• ProducerIdManager

• TransactionStateManager

• TransactionMarkerChannelManager

• Time

• LogContext

TransactionCoordinator initializes the internal registries and counters.

Creating TransactionCoordinator — apply Factory Method

apply(
  config: KafkaConfig,
  replicaManager: ReplicaManager,
  scheduler: Scheduler,
  zkClient: KafkaZkClient,
  metrics: Metrics,
  metadataCache: MetadataCache,
  time: Time): TransactionCoordinator

apply…​FIXME

Note	apply is used exclusively when KafkaServer is requested to start up (to create a TransactionCoordinator).

shutdown Method

shutdown(): Unit

shutdown…​FIXME

Note	shutdown is used when…​FIXME

abortTimedOutTransactions Internal Method

abortTimedOutTransactions(): Unit

abortTimedOutTransactions…​FIXME

Note	abortTimedOutTransactions is used when…​FIXME

partitionFor Method

partitionFor(transactionalId: String): Int

partitionFor…​FIXME

Note	partitionFor is used when…​FIXME

transactionTopicConfigs Method

transactionTopicConfigs: Properties

transactionTopicConfigs…​FIXME

Note	transactionTopicConfigs is used when KafkaApis is requested to create __transaction_state internal topic.