diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
index a0e0c191..704fc997 100644
--- 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")