[kafka] bumping kafka-python package version to 1.2.5.

[kafka] OffsetRequest is now OffsetRequestPayload [kafka] KafkaClient has changed location.
DataDog · Jul 26, 2016 · c342f50 · c342f50
1 parent 01b6704
commit c342f50
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