diff --git a/integration-test-requirements.txt b/integration-test-requirements.txt
index e088c72df8..1880655351 100644
--- a/integration-test-requirements.txt
+++ b/integration-test-requirements.txt
@@ -2,9 +2,10 @@ pytest
 pytest-localserver
 requests
 flask
+werkzeug==0.15.1
 confluent-kafka
 msgpack
 pytest-rerunfailures
-pytest-xdist
-redis
+pytest-xdist==1.31.0
+redis==3.4.1
 git+https://github.com/untitaker/pytest-sentry#egg=pytest-sentry
diff --git a/tests/integration/fixtures/processing.py b/tests/integration/fixtures/processing.py
index 1a9ae4edb7..a2a1780bf5 100644
--- a/tests/integration/fixtures/processing.py
+++ b/tests/integration/fixtures/processing.py
@@ -125,7 +125,12 @@ def inner(topic: str, options=None):
 
         consumer = kafka.Consumer(settings)
         consumer.subscribe(topics)
-        request.addfinalizer(consumer.unsubscribe)
+
+        def die():
+            consumer.unsubscribe()
+            consumer.close()
+
+        request.addfinalizer(die)
 
         while consumer.poll(timeout=0.1) is not None:
             pass