Fix send to offset to tx, when no active tx

moonyoungCHAE · moonyoungCHAE · commit be2e5b70b45f · 2025-10-05T14:21:39.000+09:00
.

Signed-off-by: moonyougnCHAE &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 (this.kafkaTxManager != null && TransactionSynchronizationManager.getResource(this.kafkaTxManager.getProducerFactory()) == null) {
+				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 (this.kafkaTxManager != null && TransactionSynchronizationManager.getResource(this.kafkaTxManager.getProducerFactory()) == null) {`
	`3084`	`+ return;`
	`3085`	`+ }`
`3083`	`3086`	`handleAcks();`
`3084`	`3087`	`Map<TopicPartition, OffsetAndMetadata> commits = buildCommits();`
`3085`	`3088`	`this.commitLogger.log(() -> "Sending offsets to transaction: " + commits);`