From c342f50a455e53f56768a0e047145137b3c2e618 Mon Sep 17 00:00:00 2001 From: Jaime Fullaondo Date: Tue, 26 Jul 2016 11:28:20 -0400 Subject: [PATCH] [kafka] bumping kafka-python package version to 1.2.5. [kafka] OffsetRequest is now OffsetRequestPayload [kafka] KafkaClient has changed location. --- checks.d/kafka_consumer.py | 4 ++-- requirements.txt | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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