diff --git a/requirements-swh.txt b/requirements-swh.txt
--- a/requirements-swh.txt
+++ b/requirements-swh.txt
@@ -3,4 +3,4 @@
 swh.objstorage >= 0.0.28
 swh.scheduler >= 0.0.47
 swh.storage >= 0.0.156
-swh.journal >= 0.0.29
+swh.journal >= 0.0.31
diff --git a/swh/indexer/cli.py b/swh/indexer/cli.py
--- a/swh/indexer/cli.py
+++ b/swh/indexer/cli.py
@@ -236,14 +236,19 @@
     on these new objects."""
     scheduler = _get_api(get_scheduler, ctx.obj["config"], "scheduler", scheduler_url)
 
-    client = get_journal_client(
-        ctx,
-        brokers=brokers,
-        prefix=prefix,
-        group_id=group_id,
-        object_types=["origin_visit"],
-        stop_after_objects=stop_after_objects,
+    ctx.obj["config"].update(
+        {
+            "journal_client": dict(
+                cls="kafka",
+                brokers=brokers,
+                prefix=prefix,
+                group_id=group_id,
+                object_types=["origin_visit"],
+                stop_after_objects=stop_after_objects,
+            )
+        }
     )
+    client = get_journal_client(ctx)
 
     worker_fn = functools.partial(
         process_journal_objects,