File tree 1 file changed +7
-3
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener
1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -507,9 +507,13 @@ public PlatformTransactionManager getTransactionManager() {
507
507
}
508
508
509
509
/**
510
- * Set the transaction manager to start a transaction; offsets are committed with
511
- * semantics equivalent to {@link AckMode#RECORD} and {@link AckMode#BATCH} depending
512
- * on the listener type (record or batch).
510
+ * Set the transaction manager to start a transaction; if it is a
511
+ * {@link org.springframework.kafka.transaction.KafkaAwareTransactionManager}, offsets
512
+ * are committed with semantics equivalent to {@link AckMode#RECORD} and
513
+ * {@link AckMode#BATCH} depending on the listener type (record or batch). For other
514
+ * transaction managers, adding the transaction manager to the container facilitates,
515
+ * for example, a record or batch interceptor participating in the same transaction
516
+ * (you must set the container's {@code interceptBeforeTx} property to false).
513
517
* @param transactionManager the transaction manager.
514
518
* @since 1.3
515
519
* @see #setAckMode(AckMode)
You can’t perform that action at this time.
0 commit comments