diff --git a/requirements-swh.txt b/requirements-swh.txt
--- a/requirements-swh.txt
+++ b/requirements-swh.txt
@@ -1,5 +1,5 @@
 # Add here internal Software Heritage dependencies, one per line.
 swh.core[http] >= 2
-swh.journal
+swh.journal >= 0.9
 swh.model >= 4.3
 swh.storage
diff --git a/swh/dataset/journalprocessor.py b/swh/dataset/journalprocessor.py
--- a/swh/dataset/journalprocessor.py
+++ b/swh/dataset/journalprocessor.py
@@ -105,7 +105,7 @@
                 self._messages_to_commit.append(message)
                 self.unsubscribe([partition_id])
 
-    def deserialize_message(self, message):
+    def deserialize_message(self, message, object_type=None):
         """
         Override of the message deserialization to hook the handling of the
         message offset.