diff --git a/checks.d/kafka_consumer.py b/checks.d/kafka_consumer.py
index 242a3ac883..95ef4fa8ee 100644
--- a/checks.d/kafka_consumer.py
+++ b/checks.d/kafka_consumer.py
@@ -6,8 +6,8 @@
 from collections import defaultdict
 
 # 3p
-from kafka.client import KafkaClient
-from kafka.common import OffsetRequest
+from kafka import KafkaClient
+from kafka.common import OffsetRequestPayload as OffsetRequest
 from kazoo.client import KazooClient
 from kazoo.exceptions import NoNodeError
 
diff --git a/requirements.txt b/requirements.txt
index f01cd405d4..a982bd5136 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -44,7 +44,7 @@ pyro4==4.35 # required by adodbapi
 httplib2==0.9
 
 # checks.d/kafka_consumer.py
-kafka-python==0.9.3
+kafka-python==1.2.5
 
 # checks.d/postgres.py
 pg8000==1.10.1