We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bdd89b6 commit 369ffa6Copy full SHA for 369ffa6
spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -2064,7 +2064,7 @@ public void testPauseResume() throws Exception {
2064
}
2065
return first.getAndSet(false) ? consumerRecords : emptyRecords;
2066
});
2067
- final CountDownLatch commitLatch = new CountDownLatch(2);
+ final CountDownLatch commitLatch = new CountDownLatch(3);
2068
willAnswer(i -> {
2069
commitLatch.countDown();
2070
return null;
0 commit comments