diff --git a/swh/journal/tests/test_cli.py b/swh/journal/tests/test_cli.py
--- a/swh/journal/tests/test_cli.py
+++ b/swh/journal/tests/test_cli.py
@@ -94,7 +94,7 @@
     producer = Producer({
         'bootstrap.servers': 'localhost:{}'.format(kafka_port),
         'client.id': 'test-producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     snapshot = {'id': b'foo', 'branches': {
@@ -156,7 +156,7 @@
     producer = Producer({
         'bootstrap.servers': '127.0.0.1:{}'.format(kafka_port),
         'client.id': 'test-producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     contents = {}
diff --git a/swh/journal/tests/test_client.py b/swh/journal/tests/test_client.py
--- a/swh/journal/tests/test_client.py
+++ b/swh/journal/tests/test_client.py
@@ -27,7 +27,7 @@
     producer = Producer({
         'bootstrap.servers': 'localhost:{}'.format(port),
         'client.id': 'test producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     rev = revisions().example()
@@ -61,7 +61,7 @@
     producer = Producer({
         'bootstrap.servers': 'localhost:{}'.format(port),
         'client.id': 'test producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     rev = revisions().example()
@@ -103,7 +103,7 @@
     producer = Producer({
         'bootstrap.servers': 'localhost:{}'.format(port),
         'client.id': 'test producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     contents = [Content.from_data(bytes([i])) for i in range(num_objects)]
diff --git a/swh/journal/tests/test_replay.py b/swh/journal/tests/test_replay.py
--- a/swh/journal/tests/test_replay.py
+++ b/swh/journal/tests/test_replay.py
@@ -45,7 +45,7 @@
     producer = Producer({
         'bootstrap.servers': 'localhost:{}'.format(port),
         'client.id': 'test producer',
-        'enable.idempotence': 'true',
+        'acks': 'all',
     })
 
     now = datetime.datetime.now(tz=datetime.timezone.utc)
diff --git a/swh/journal/writer/kafka.py b/swh/journal/writer/kafka.py
--- a/swh/journal/writer/kafka.py
+++ b/swh/journal/writer/kafka.py
@@ -34,7 +34,7 @@
             'on_delivery': self._on_delivery,
             'error_cb': self._error_cb,
             'logger': logger,
-            'enable.idempotence': 'true',
+            'acks': 'all',
             **producer_config,
         })