fix circle reference

zz000 · zz000 · commit c6a5aafa40ad · 2015-02-02T10:49:02.000+08:00
diff --git a/kafka/util.py b/kafka/util.py
@@ -146,3 +146,4 @@ def stop(self):
         self.thread.join(self.t + 1)
         # noinspection PyAttributeOutsideInit
         self.timer = None
+        self.fn = None
