diff --git a/swh/journal/tests/test_kafka_writer.py b/swh/journal/tests/test_kafka_writer.py
--- a/swh/journal/tests/test_kafka_writer.py
+++ b/swh/journal/tests/test_kafka_writer.py
@@ -100,9 +100,7 @@
             )
 
 
-def test_write_delivery_failure(
-    kafka_prefix: str, kafka_server: str, consumer: Consumer
-):
+def test_write_delivery_failure(kafka_prefix: str, kafka_server: str):
     class MockKafkaError:
         """A mocked kafka error"""
 
@@ -138,9 +136,7 @@
     assert delivery_failure.code == "SWH_MOCK_ERROR"
 
 
-def test_write_delivery_timeout(
-    kafka_prefix: str, kafka_server: str, consumer: Consumer
-):
+def test_write_delivery_timeout(kafka_prefix: str, kafka_server: str):
 
     produced = []