We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 41f7f31 commit a108a33Copy full SHA for a108a33
spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -3080,7 +3080,7 @@ else if (!this.autoCommit && (!this.isAnyManualAck || commitRecovered)) {
3080
}
3081
3082
private void sendOffsetsToTransaction() {
3083
- if (this.kafkaTxManager != null && TransactionSynchronizationManager.getResource(this.kafkaTxManager.getProducerFactory()) == null) {
+ if (this.kafkaTxManager == null || TransactionSynchronizationManager.getResource(this.kafkaTxManager.getProducerFactory()) == null) {
3084
return;
3085
3086
handleAcks();
0 commit comments