diff --git a/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerUnitTest.java b/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerUnitTest.java
index 500962311e..20a78f0251 100644
--- a/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerUnitTest.java
+++ b/spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerUnitTest.java
@@ -76,7 +76,7 @@ public class StartStopConsumerUnitTest {
         this.userEventStore.clearUserEvents();
     }
 
-    /*@Test
+    @Test
     void processMessages_whenListenerIsRestarted_thenCorrectNumberOfMessagesAreConsumed() throws ExecutionException, InterruptedException {
         kafkaListenerControlService.startListener(Constants.LISTENER_ID);
 
@@ -103,5 +103,5 @@ public class StartStopConsumerUnitTest {
         kafkaListenerControlService.startListener(Constants.LISTENER_ID);
         await().untilAsserted(() -> assertEquals(6, this.userEventStore.getUserEvents().size()));
         kafkaListenerControlService.stopListener(Constants.LISTENER_ID);
-    }*/
+    }
 }
\ No newline at end of file