Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-2428: Fix Test for Back Port

Browse Source
This commit is contained in:
Gary Russell
2023-01-04 09:44:05 -05:00
parent 02abe6bf5c
commit b4a71909df
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka/src/test/java/org/springframework/kafka/listener/DeadLetterPublishingRecovererTests.java
View File

@@ -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<String, String> record = new ConsumerRecord<>("foo", 0, 0L, 0L, TimestampType.NO_TIMESTAMP_TYPE,