From b4a71909df90b4ebe6916d6ed61a8e82d4e415c8 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 4 Jan 2023 09:44:05 -0500 Subject: [PATCH] GH-2428: Fix Test for Back Port --- .../kafka/listener/DeadLetterPublishingRecovererTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/DeadLetterPublishingRecovererTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/DeadLetterPublishingRecovererTests.java index c829e4e6..1fccb92c 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/DeadLetterPublishingRecovererTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/DeadLetterPublishingRecovererTests.java @@ -883,7 +883,7 @@ public class DeadLetterPublishingRecovererTests { @Test void replaceNotAppendHeader() { KafkaOperations template = mock(KafkaOperations.class); - CompletableFuture future = mock(CompletableFuture.class); + ListenableFuture future = mock(ListenableFuture.class); given(template.send(any(ProducerRecord.class))).willReturn(future); Headers headers = new RecordHeaders().add(new RecordHeader("foo", "orig".getBytes())); ConsumerRecord record = new ConsumerRecord<>("foo", 0, 0L, 0L, TimestampType.NO_TIMESTAMP_TYPE,