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.

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

results matching ""

    No results matching ""