diff --git a/requirements-swh.txt b/requirements-swh.txt
index 68754744a..f6eca736b 100644
--- a/requirements-swh.txt
+++ b/requirements-swh.txt
@@ -1,5 +1,4 @@
 swh.core >= 0.0.28
 swh.model >= 0.0.18
 swh.objstorage >= 0.0.17
 swh.scheduler >= 0.0.14
-swh.journal >= 0.0.2
diff --git a/requirements.txt b/requirements.txt
index 1c4adeff9..c08b7c50c 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,7 +1,7 @@
 click
 flask
 psycopg2
 python-dateutil
 vcversioner
-kafka
+kafka_python
 aiohttp