diff --git a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
index 993c138..ea00251 100644
--- a/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
+++ b/src/test/java/com/googlesource/gerrit/plugins/multisite/kafka/consumer/EventConsumerIT.java
@@ -89,11 +89,12 @@
     drainQueue(droppedEventsQueue);
 
     createChange();
-    List<String> createdChangeEvents = receiveFromQueue(droppedEventsQueue, 2);
-    assertThat(createdChangeEvents).hasSize(2);
+    List<String> createdChangeEvents = receiveFromQueue(droppedEventsQueue, 3);
+    assertThat(createdChangeEvents).hasSize(3);
 
     assertThat(createdChangeEvents).contains("change-index");
     assertThat(createdChangeEvents).contains("ref-updated");
+    assertThat(createdChangeEvents).contains("patchset-created");
   }
 
   @Test