diff --git a/requirements.in b/requirements.in
index 928eef8..16dc462 100644
--- a/requirements.in
+++ b/requirements.in
@@ -25,8 +25,8 @@
 cryptography
 gnocchiclient
 humanfriendly
+kafka-python
 lxml
-kafka
 prometheus-api-client
 prometheus-client
 python-ceilometerclient
diff --git a/requirements.txt b/requirements.txt
index 47520fa..b78ca8d 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -94,7 +94,7 @@
     # via openstacksdk
 jsonpointer==3.0.0
     # via jsonpatch
-kafka==1.3.5
+kafka-python==2.0.2
     # via -r requirements.in
 keystoneauth1==5.7.0
     # via