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() {
553553 }
554554
555555 /**
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).
559563 * @param transactionManager the transaction manager.
560564 * @since 1.3
561565 * @see #setAckMode(AckMode)
You can’t perform that action at this time.
0 commit comments