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:

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.

results matching ""

    No results matching ""