diff options
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/consumer/base.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/kafka.py | 4 | ||||
| -rw-r--r-- | kafka/consumer/multiprocess.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/simple.py | 2 |
4 files changed, 5 insertions, 5 deletions
diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py index a90038f..2059d92 100644 --- a/kafka/consumer/base.py +++ b/kafka/consumer/base.py @@ -94,7 +94,7 @@ class Consumer(object): def fetch_last_known_offsets(self, partitions=None): if self.group is None: - raise ValueError('KafkaClient.group must not be None') + raise ValueError('SimpleClient.group must not be None') if partitions is None: partitions = self.client.get_partition_ids_for_topic(self.topic) 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) diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py index a348d1a..9358b09 100644 --- a/kafka/consumer/multiprocess.py +++ b/kafka/consumer/multiprocess.py @@ -102,7 +102,7 @@ class MultiProcessConsumer(Consumer): parallel using multiple processes Arguments: - client: a connected KafkaClient + client: a connected SimpleClient group: a name for this consumer, used for offset storage and must be unique If you are connecting to a server that does not support offset commit/fetch (any prior to 0.8.1.1), then you *must* set this to None diff --git a/kafka/consumer/simple.py b/kafka/consumer/simple.py index abeac7b..29eb480 100644 --- a/kafka/consumer/simple.py +++ b/kafka/consumer/simple.py @@ -70,7 +70,7 @@ class SimpleConsumer(Consumer): for a topic Arguments: - client: a connected KafkaClient + client: a connected SimpleClient group: a name for this consumer, used for offset storage and must be unique If you are connecting to a server that does not support offset commit/fetch (any prior to 0.8.1.1), then you *must* set this to None |