From 9a8af1499ca425366d934487469d9977fae7fe5f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 7 Jan 2016 17:57:24 -0800 Subject: Fix KafkaClient->SimpleClient references --- kafka/consumer/kafka.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/consumer/kafka.py') diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py index 3f14444..29ddd0e 100644 --- a/kafka/consumer/kafka.py +++ b/kafka/consumer/kafka.py @@ -9,7 +9,7 @@ import time import six -from kafka.client import KafkaClient +from kafka import SimpleClient from kafka.common import ( OffsetFetchRequestPayload, OffsetCommitRequestPayload, OffsetRequestPayload, FetchRequestPayload, @@ -136,7 +136,7 @@ class KafkaConsumer(object): 'bootstrap_servers required to configure KafkaConsumer' ) - self._client = KafkaClient( + self._client = SimpleClient( self._config['bootstrap_servers'], client_id=self._config['client_id'], timeout=(self._config['socket_timeout_ms'] / 1000.0) -- cgit v1.2.1