TransactionStateManager

TransactionStateManager is…​FIXME

getTransactionTopicPartitionCount Method

getTransactionTopicPartitionCount

getTransactionTopicPartitionCount…​FIXME

Note
 getTransactionTopicPartitionCount is used when…​FIXME

enableTransactionalIdExpiration Method

enableTransactionalIdExpiration(): Unit

enableTransactionalIdExpiration…​FIXME

Note
 enableTransactionalIdExpiration is used when…​FIXME

loadTransactionsForTxnTopicPartition Method

loadTransactionsForTxnTopicPartition(
  partitionId: Int,
  coordinatorEpoch: Int,
  sendTxnMarkers: SendTxnMarkersCallback): Unit

loadTransactionsForTxnTopicPartition…​FIXME

Note
 loadTransactionsForTxnTopicPartition is used when…​FIXME

removeTransactionsForTxnTopicPartition Method

removeTransactionsForTxnTopicPartition(partitionId: Int, coordinatorEpoch: Int): Unit

removeTransactionsForTxnTopicPartition…​FIXME

Note
 removeTransactionsForTxnTopicPartition is used when…​FIXME

loadTransactions Method

loadTransactions(): Unit

loadTransactions…​FIXME

Note
 loadTransactions is used when…​FIXME

removeTransactions Method

removeTransactions(): Unit

removeTransactions…​FIXME

Note
 removeTransactions is used when…​FIXME

appendTransactionToLog Method

appendTransactionToLog(
  transactionalId: String,
  coordinatorEpoch: Int,
  newMetadata: TxnTransitMetadata,
  responseCallback: Errors => Unit,
  retryOnError: Errors => Boolean = _ => false): Unit

appendTransactionToLog…​FIXME

Note
 appendTransactionToLog is used when…​FIXME

transactionTopicConfigs Method

transactionTopicConfigs: Properties

transactionTopicConfigs…​FIXME

Note
 transactionTopicConfigs is used when TransactionCoordinator is requested for the transactionTopicConfigs.

loadTransactionMetadata Internal Method

loadTransactionMetadata(
  topicPartition: TopicPartition,
  coordinatorEpoch: Int): Pool[String, TransactionMetadata]

loadTransactionMetadata…​FIXME

Note
 loadTransactionMetadata is used when…​FIXME

results matching ""

    No results matching ""