diff --git a/samza-test/src/main/python/requirements.txt b/samza-test/src/main/python/requirements.txt
index 33e9db5c36..bff9962a27 100644
--- a/samza-test/src/main/python/requirements.txt
+++ b/samza-test/src/main/python/requirements.txt
@@ -17,6 +17,6 @@
 
 zopkio==0.2.5
 requests
-kafka-python==1.3.3
+kafka-python==2.3.2
 Jinja2
 kazoo==2.8.0