diff --git a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
index 795ce26..044409a 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumer.java
@@ -81,6 +81,6 @@
   @Override
   public void stop() {
     shutdownState.setIsShuttingDown(true);
-    eventsBrokerDi.get().disconnect();
+    eventsBrokerDi.get().disconnect(eventsTopicName, groupId);
   }
 }
diff --git a/src/test/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumerTest.java b/src/test/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumerTest.java
index 0aba20a..9e57d9f 100644
--- a/src/test/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumerTest.java
+++ b/src/test/java/com/googlesource/gerrit/plugins/replication/pull/event/EventsBrokerMessageConsumerTest.java
@@ -77,6 +77,6 @@
     shutdownState.setIsShuttingDown(true);
 
     objectUnderTest.accept(new RefUpdatedEvent());
-    verify(eventsBroker, times(1)).disconnect();
+    verify(eventsBroker, times(1)).disconnect("topicName", null);
   }
 }