diff --git a/requirements-swh.txt b/requirements-swh.txt
--- a/requirements-swh.txt
+++ b/requirements-swh.txt
@@ -1,2 +1,2 @@
 swh.core
-swh.storage >= 0.0.117
+swh.storage >= 0.0.135
diff --git a/swh/journal/tests/test_direct_writer.py b/swh/journal/tests/test_direct_writer.py
--- a/swh/journal/tests/test_direct_writer.py
+++ b/swh/journal/tests/test_direct_writer.py
@@ -4,6 +4,7 @@
 # See top-level LICENSE file for more information
 
 from collections import defaultdict
+import datetime
 import time
 
 from kafka import KafkaConsumer
@@ -36,6 +37,9 @@
         if object_type == 'origin_visit':
             for value in values:
                 del value['visit']
+        elif object_type == 'content':
+            for value in values:
+                del value['ctime']
 
         for object_ in objects:
             assert kafka_to_value(value_to_kafka(object_)) in values
@@ -59,6 +63,8 @@
         for (num, object_) in enumerate(objects):
             if object_type == 'origin_visit':
                 object_ = {**object_, 'visit': num}
+            if object_type == 'content':
+                object_ = {**object_, 'ctime': datetime.datetime.now()}
             writer.write_addition(object_type, object_)
 
     assert_written(consumer_from_publisher, kafka_prefix)