diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-07 17:57:24 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-07 17:57:24 -0800 |
| commit | 9a8af1499ca425366d934487469d9977fae7fe5f (patch) | |
| tree | 01ad6026ca2ecf62e554f4fabacc045b46c01737 /kafka/consumer/base.py | |
| parent | d4e85ecd1d8acac1a0f74d164b67faefd99987e4 (diff) | |
| download | kafka-python-0.9.tar.gz | |
Fix KafkaClient->SimpleClient references0.9
Diffstat (limited to 'kafka/consumer/base.py')
| -rw-r--r-- | kafka/consumer/base.py | 2 |
1 files changed, 1 insertions, 1 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) |