Stop consumers on delete

Author: Dana Powers

kafka/consumer/base.py

@@ -143,6 +143,9 @@ def _auto_commit(self):
         if self.count_since_commit >= self.auto_commit_every_n:
             self.commit()
 
+    def __del__(self):
+        self.stop()
+
     def stop(self):
         if self.commit_timer is not None:
             self.commit_timer.stop()