diff --git a/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaTemplateTests.java b/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaTemplateTests.java index 60e1d988..bf21fa0f 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaTemplateTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/core/KafkaTemplateTests.java @@ -454,7 +454,7 @@ public class KafkaTemplateTests { final CountDownLatch latch = new CountDownLatch(1); final AtomicReference> theResult = new AtomicReference<>(); AtomicReference value = new AtomicReference<>(); - future.addCallback(result -> {}, (KafkaFailureCallback) ex -> { + future.addCallback(result -> { }, (KafkaFailureCallback) ex -> { ProducerRecord failed = ex.getFailedProducerRecord(); value.set(failed.value()); latch.countDown();