From bb68965b9e530de7413c6ac98ef13c06158e2d91 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Mon, 30 Mar 2015 11:05:48 -0700
Subject: [PATCH] Stop consumers on delete

---
 kafka/consumer/base.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py
index efc94040e..bde3c1ad0 100644
--- a/kafka/consumer/base.py
+++ b/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()