diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java index 05bf827480..c0fe33e720 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java @@ -116,6 +116,7 @@ * @author Thomas Strauß * @author Adrian Gygax * @author Soby Chacko + * @author Jaeyeon Kim */ public class DefaultKafkaProducerFactory extends KafkaResourceFactory implements ProducerFactory, ApplicationContextAware, @@ -1181,13 +1182,11 @@ public void commitTransaction() throws ProducerFencedException { @Override public void abortTransaction() throws ProducerFencedException { - LOGGER.debug(() -> toString() + " abortTransaction()"); - if (this.producerFailed != null) { - LOGGER.debug(() -> { - String message = this.producerFailed == null ? "" : this.producerFailed.getMessage(); - return "abortTransaction ignored - previous txFailed: " + message - + ": " + this; - }); + Exception producerFailedToUse = this.producerFailed; + LOGGER.debug(() -> this + " abortTransaction()"); + if (producerFailedToUse != null) { + LOGGER.debug(() -> "abortTransaction ignored - previous txFailed: " + producerFailedToUse.getMessage() + + ": " + this); } else { try {