rreddy-22 commented on code in PR #19539:
URL: https://github.com/apache/kafka/pull/19539#discussion_r2085651776
##########
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:
I just remembered that we don't use get or set explicitly in AK, will rename
it preparedTransactionState()
--
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]
