GH-2501: Fix Race in Test

2022-12-07 16:16:32 -05:00
parent b4956d4dbf
commit bdada69d67
1 changed files with 1 additions and 1 deletions
--- a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
+++ b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
@@ -2210,8 +2210,8 @@ public class EnableKafkaIntegrationTests {
 		public void projectionListener(ProjectionSample sample) {
 			this.username = sample.getUsername();
 			this.name = sample.getName();
-			this.projectionLatch.countDown();
 			this.customThreadName = Thread.currentThread().getName();
+			this.projectionLatch.countDown();
 		}

 		@KafkaListener(id = "customMethodArgumentResolver", topics = "annotated39")