Addressing PR review

spring-projects · Mar 28, 2024 · 8b9164b · 8b9164b
1 parent 85fbfaf
commit 8b9164b
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/.../src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java b/.../src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -4252,9 +4252,7 @@ public void invokeBatchInterceptorSuccessFailureOnRetry() throws Exception {
 		ConsumerRecords<Integer, String> consumerRecords = new ConsumerRecords<>(records);
 		AtomicInteger invocation = new AtomicInteger(0);
 		given(consumer.poll(any(Duration.class))).willAnswer(i -> {
-			Thread.sleep(50);
-			if (invocation.get() == 0) {
-				invocation.getAndIncrement();
+			if (invocation.getAndIncrement() == 0) {
 				return consumerRecords;
 			}
 			else {