File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -553,9 +553,13 @@ public PlatformTransactionManager getTransactionManager() {
553
553
}
554
554
555
555
/**
556
- * Set the transaction manager to start a transaction; offsets are committed with
557
- * semantics equivalent to {@link AckMode#RECORD} and {@link AckMode#BATCH} depending
558
- * on the listener type (record or batch).
556
+ * Set the transaction manager to start a transaction; if it is a
557
+ * {@link org.springframework.kafka.transaction.KafkaAwareTransactionManager}, offsets
558
+ * are committed with semantics equivalent to {@link AckMode#RECORD} and
559
+ * {@link AckMode#BATCH} depending on the listener type (record or batch). For other
560
+ * transaction managers, adding the transaction manager to the container facilitates,
561
+ * for example, a record or batch interceptor participating in the same transaction
562
+ * (you must set the container's {@code interceptBeforeTx} property to false).
559
563
* @param transactionManager the transaction manager.
560
564
* @since 1.3
561
565
* @see #setAckMode(AckMode)
You can’t perform that action at this time.
0 commit comments