diff options
| author | Mark Roberts <wizzat@gmail.com> | 2014-04-30 18:09:45 -0700 |
|---|---|---|
| committer | Mark Roberts <wizzat@gmail.com> | 2014-04-30 18:09:45 -0700 |
| commit | 636778a11fa638a1a58d35af123c62d7c3d2adc2 (patch) | |
| tree | 76daa5d882ea48dcae06890e8233f0609e2da1f4 | |
| parent | 7a7a8186cc5eed803b0aba8bda71a1e760de30f9 (diff) | |
| download | kafka-python-636778a11fa638a1a58d35af123c62d7c3d2adc2.tar.gz | |
Make commit() check for errors instead of simply assert no error
| -rw-r--r-- | kafka/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 43b8797..085f5e8 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -152,7 +152,7 @@ class Consumer(object): resps = self.client.send_offset_commit_request(self.group, reqs) for resp in resps: - assert resp.error == 0 + kafka.common.check_error(resp) self.count_since_commit = 0 |