Fix commit latch count

spring-projects · Jun 3, 2019 · 9d8adf2 · 9d8adf2
1 parent ebe4c9b
commit 9d8adf2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java b/.../src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -1885,7 +1885,7 @@ public void testPauseResume() throws Exception {
 			}
 			return first.getAndSet(false) ? consumerRecords : emptyRecords;
 		});
-		final CountDownLatch commitLatch = new CountDownLatch(2);
+		final CountDownLatch commitLatch = new CountDownLatch(3);
 		willAnswer(i -> {
 			commitLatch.countDown();
 			return null;
@@ -1934,7 +1934,7 @@ else if (e instanceof ConsumerStoppedEvent) {
 		});
 		container.start();
 		assertThat(commitLatch.await(10, TimeUnit.SECONDS)).isTrue();
-		verify(consumer, atLeast(3)).commitSync(anyMap());
+		verify(consumer, times(3)).commitSync(anyMap());
 		assertThat(container.isContainerPaused()).isFalse();
 		container.pause();
 		assertThat(container.isPaused()).isTrue();