Merge pull request #2709 from DataDog/jaime/kafkabump

[kafka] bumping kafka-python package version to 1.2.5.
DataDog · Aug 12, 2016 · 6abedef · 6abedef
2 parents 4eb999d + c342f50
commit 6abedef
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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