We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5ccb444 commit 4618b63Copy full SHA for 4618b63
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
@@ -307,6 +307,9 @@ synchronized TransactionalRequestResult initializeTransactions(
307
if (!isEpochBump) {
308
transitionTo(State.INITIALIZING);
309
log.info("Invoking InitProducerId for the first time in order to acquire a producer ID");
310
+ if (keepPreparedTxn) {
311
+ log.info("Invoking InitProducerId with keepPreparedTxn set to true for 2PC transactions");
312
+ }
313
} else {
314
log.info("Invoking InitProducerId with current producer ID and epoch {} in order to bump the epoch", producerIdAndEpoch);
315
}
0 commit comments