diff --git a/tests/integration/fixtures/processing.py b/tests/integration/fixtures/processing.py
index b3580577ed..ef45e4dfc2 100644
--- a/tests/integration/fixtures/processing.py
+++ b/tests/integration/fixtures/processing.py
@@ -156,7 +156,7 @@ def __init__(self, consumer, options, topic_name, timeout=None):
         self.consumer = consumer
         self.test_producer = kafka_producer(options)
         self.topic_name = topic_name
-        self.timeout = timeout or 1
+        self.timeout = timeout or 2
 
         # Connect to the topic and poll a first test message.
         # First poll takes forever, the next ones are fast.