From b91f49d7b37bc0d841c2a17f2104fd161082c3f6 Mon Sep 17 00:00:00 2001
From: onobc <onobc@apache.org>
Date: Thu, 15 Feb 2024 21:25:55 -0600
Subject: [PATCH] Fix flaky AdaptedReactiveMessageConsumerTests

The consumeManyAndAcknowledge() tests has been flaky. This commit
increase the `take` window from 100ms to 200ms to allow the messages to
be emitted.
---
 .../internal/adapter/AdaptedReactiveMessageConsumerTests.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
index 96babd1..2fbc7da 100644
--- a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
+++ b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
@@ -366,7 +366,7 @@ void consumeManyAndAcknowledge() throws Exception {
 
 		StepVerifier
 			.create(reactiveConsumer.consumeMany((messages) -> messages.map(MessageResult::acknowledgeAndReturn))
-				.take(Duration.ofMillis(100)))
+				.take(Duration.ofMillis(200)))
 			.expectNext(message1)
 			.expectNext(message2)
 			.verifyComplete();