TransactionStateManager
is…FIXME
getTransactionTopicPartitionCount
getTransactionTopicPartitionCount
…FIXME
Note
|
getTransactionTopicPartitionCount is used when…FIXME
|
enableTransactionalIdExpiration(): Unit
enableTransactionalIdExpiration
…FIXME
Note
|
enableTransactionalIdExpiration is used when…FIXME
|
loadTransactionsForTxnTopicPartition(
partitionId: Int,
coordinatorEpoch: Int,
sendTxnMarkers: SendTxnMarkersCallback): Unit
loadTransactionsForTxnTopicPartition
…FIXME
Note
|
loadTransactionsForTxnTopicPartition is used when…FIXME
|
removeTransactionsForTxnTopicPartition(partitionId: Int, coordinatorEpoch: Int): Unit
removeTransactionsForTxnTopicPartition
…FIXME
Note
|
removeTransactionsForTxnTopicPartition is used when…FIXME
|
loadTransactions(): Unit
loadTransactions
…FIXME
Note
|
loadTransactions is used when…FIXME
|
removeTransactions(): Unit
removeTransactions
…FIXME
Note
|
removeTransactions is used when…FIXME
|
appendTransactionToLog(
transactionalId: String,
coordinatorEpoch: Int,
newMetadata: TxnTransitMetadata,
responseCallback: Errors => Unit,
retryOnError: Errors => Boolean = _ => false): Unit
appendTransactionToLog
…FIXME
Note
|
appendTransactionToLog is used when…FIXME
|
transactionTopicConfigs: Properties
transactionTopicConfigs
…FIXME
Note
|
transactionTopicConfigs is used when TransactionCoordinator is requested for the transactionTopicConfigs.
|