diff --git a/swh/journal/client.py b/swh/journal/client.py
--- a/swh/journal/client.py
+++ b/swh/journal/client.py
@@ -7,7 +7,7 @@
 import logging
 import time
 
-from confluent_kafka import Consumer, KafkaException
+from confluent_kafka import Consumer, KafkaException, KafkaError
 
 from .serializers import kafka_to_value
 from swh.journal import DEFAULT_PREFIX
@@ -34,6 +34,8 @@
 def _error_cb(error):
     if error.fatal():
         raise KafkaException(error)
+    if error.code() == KafkaError._NO_OFFSET:
+        return  # this "error" is useless and too spammy
     logger.info('Received non-fatal kafka error: %s', error)