diff --git a/swh/storage/tests/test_replay.py b/swh/storage/tests/test_replay.py
--- a/swh/storage/tests/test_replay.py
+++ b/swh/storage/tests/test_replay.py
@@ -319,7 +319,7 @@
     dst_storage = get_storage(cls="memory")
     replayer = JournalClient(
         brokers=kafka_server,
-        group_id=kafka_consumer_group,
+        group_id=f"{kafka_consumer_group}-2",
         prefix=kafka_prefix,
         stop_after_objects=nb_sent,
         privileged=True,