summaryrefslogtreecommitdiff
path: root/kafka/util.py
diff options
context:
space:
mode:
authorzhaopengzp <makicn@gmail.com>2015-02-02 10:49:02 +0800
committerzhaopengzp <makicn@gmail.com>2015-02-02 10:49:02 +0800
commitc6a5aafa40ad249dda17072a7f02853bbae3a0ff (patch)
tree2b2ebff928d9534e624bd4669e7acf3edbac3861 /kafka/util.py
parent587206ff6ad59ae01248d24ff9c9fadbdfc1c1fc (diff)
downloadkafka-python-c6a5aafa40ad249dda17072a7f02853bbae3a0ff.tar.gz
fix circle reference
Diffstat (limited to 'kafka/util.py')
-rw-r--r--kafka/util.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/util.py b/kafka/util.py
index 622b1a7..cc5c0d5 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -146,3 +146,4 @@ class ReentrantTimer(object):
self.thread.join(self.t + 1)
# noinspection PyAttributeOutsideInit
self.timer = None
+ self.fn = None