diff --git a/kafka/requirements.txt b/kafka/requirements.txt
index 39a9d9b..c34dad1 100644
--- a/kafka/requirements.txt
+++ b/kafka/requirements.txt
@@ -1,4 +1,4 @@
 Faker==13.13.0
-kafka-python==2.0.2
+kafka-python==2.3.2
 python-dateutil==2.8.2
 six==1.16.0