Skip to content

Commit f8eb136

Browse files
committed
Fix KafkaMLCTests for proper number in CountDownLatch
1 parent 6f33e44 commit f8eb136

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3841,7 +3841,7 @@ public void onMessage(ConsumerRecord<Integer, String> data) {
38413841
containerProps.setMessageListener(messageListener);
38423842
containerProps.setClientId("clientId");
38433843

3844-
CountDownLatch afterLatch = new CountDownLatch(1);
3844+
CountDownLatch afterLatch = new CountDownLatch(2);
38453845
RecordInterceptor<Integer, String> recordInterceptor1 = spy(new RecordInterceptor<Integer, String>() {
38463846

38473847
@Override

0 commit comments

Comments
 (0)