diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 1 |
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 |