Fix send offest to tx, when no active tx

moonyoungCHAE · moonyoungCHAE · commit debd10917309 · 2025-10-03T22:53:49.000+09:00
Signed-off-by: moonyoungCHAE &lt;xpf_fl@naver.com&gt;
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -3080,6 +3080,9 @@ else if (!this.autoCommit && (!this.isAnyManualAck || commitRecovered)) {
 		}
 
 		private void sendOffsetsToTransaction() {
+			if (!TransactionSynchronizationManager.isActualTransactionActive()) {
+				return;
+			}
 			handleAcks();
 			Map<TopicPartition, OffsetAndMetadata> commits = buildCommits();
 			this.commitLogger.log(() -> "Sending offsets to transaction: " + commits);

Original file line number	Diff line number	Diff line change
`@@ -3080,6 +3080,9 @@ else if (!this.autoCommit && (!this.isAnyManualAck \|\| commitRecovered)) {`
`3080`	`3080`	`}`
`3081`	`3081`
`3082`	`3082`	`private void sendOffsetsToTransaction() {`
	`3083`	`+ if (!TransactionSynchronizationManager.isActualTransactionActive()) {`
	`3084`	`+ return;`
	`3085`	`+ }`
`3083`	`3086`	`handleAcks();`
`3084`	`3087`	`Map<TopicPartition, OffsetAndMetadata> commits = buildCommits();`
`3085`	`3088`	`this.commitLogger.log(() -> "Sending offsets to transaction: " + commits);`