rreddy-22 commented on code in PR #19539:
URL: https://github.com/apache/kafka/pull/19539#discussion_r2085687333
##########
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##########
@@ -1904,5 +1933,15 @@ private PendingStateTransition(
}
}
-
+ /**
+ * Returns a PreparedTxnState object containing the current producer ID
and epoch.
+ * This is used when preparing a transaction for a two-phase commit.
+ *
+ * @return a PreparedTxnState with the current producer ID and epoch
+ */
+ public PreparedTxnState getPreparedTransactionState() {
Review Comment:
Also changed how we store and update the preparedTxn state to make it easier
for the complete transaction method implementation
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
