add preparedTxnReset on completeTransaction

rreddy-22 · rreddy-22 · commit 488feeb08e73 · 2025-05-14T16:13:14.000-07:00
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
@@ -1332,6 +1332,7 @@ private void completeTransaction() {
         newPartitionsInTransaction.clear();
         pendingPartitionsInTransaction.clear();
         partitionsInTransaction.clear();
+        preparedTxnState = new PreparedTxnState();
     }
 
     abstract class TxnRequestHandler implements RequestCompletionHandler {

Original file line number	Diff line number	Diff line change
`@@ -1332,6 +1332,7 @@ private void completeTransaction() {`
`1332`	`1332`	`newPartitionsInTransaction.clear();`
`1333`	`1333`	`pendingPartitionsInTransaction.clear();`
`1334`	`1334`	`partitionsInTransaction.clear();`
	`1335`	`+ preparedTxnState = new PreparedTxnState();`
`1335`	`1336`	`}`
`1336`	`1337`
`1337`	`1338`	`abstract class TxnRequestHandler implements RequestCompletionHandler {`