Shekharrajak commented on code in PR #22357:
URL: https://github.com/apache/kafka/pull/22357#discussion_r3443000135
##########
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##########
@@ -384,7 +384,7 @@ public synchronized void beginTransaction() {
/**
* Prepare a transaction for a two-phase commit.
* This transitions the transaction to the PREPARED_TRANSACTION state.
- * The preparedTxnState is set with the current producer ID and epoch.
+ * The preparedTxnState is set with the current transaction owner fence.
Review Comment:
Share ack transaction staging/finalization internals now use txnOwnerId /
txnOwnerEpoch across SharePartition, SharePartitionManager, InFlightState,
InFlightBatch, and share coordinator
completion paths.
This will help in external procesing engine to use it as txn and engine
coord will run commit during checkpoint or completion of all the jobs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
