Pb with java future

MAIF · May 15, 2024 · 44ed85b · 44ed85b
1 parent 626d9e6
commit 44ed85b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-kafka-consumer-akka/src/test/java/fr/maif/kafka/consumer/ResilientKafkaConsumerTest.java b/...-kafka-consumer-akka/src/test/java/fr/maif/kafka/consumer/ResilientKafkaConsumerTest.java
@@ -146,7 +146,7 @@ void crash() throws Exception {
                                 return completableFuture;
                             } else {
                                 names.set(names.get() + " " + messageAndIndex.first().record().value());
-                                return CompletionStages.completedStage(messageAndIndex.first().committableOffset());
+                                return CompletableFuture.completedStage(messageAndIndex.first().committableOffset());
                             }
                         })
         );