Make commit() check for errors instead of simply assert no error

wizzat · wizzat · commit 636778a11fa6 · 2014-04-30T18:09:45.000-07:00
diff --git a/kafka/consumer.py b/kafka/consumer.py
@@ -152,7 +152,7 @@ def commit(self, partitions=None):
 
             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
 
