diff options
author | Enrico Canzonieri <ecanzonieri@gmail.com> | 2015-01-26 15:01:51 -0800 |
---|---|---|
committer | Enrico Canzonieri <enrico@yelp.com> | 2015-01-26 15:01:51 -0800 |
commit | 9ab8415ed75b08c5de9f823708027bb4f10a0643 (patch) | |
tree | f2011cb5cbdc4d5cd3d9bff9c52b35c2a6aca2ad /kafka/util.py | |
parent | f517ddf283a86947a15f95e5ec562e81f4c477e5 (diff) | |
parent | 587206ff6ad59ae01248d24ff9c9fadbdfc1c1fc (diff) | |
download | kafka-python-9ab8415ed75b08c5de9f823708027bb4f10a0643.tar.gz |
Merge branch 'master' of github.com:mumrah/kafka-python into validate_consumer_offset
Conflicts:
kafka/consumer/simple.py
Diffstat (limited to 'kafka/util.py')
-rw-r--r-- | kafka/util.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/kafka/util.py b/kafka/util.py index 72ac521..622b1a7 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -103,10 +103,12 @@ class ReentrantTimer(object): A timer that can be restarted, unlike threading.Timer (although this uses threading.Timer) - t: timer interval in milliseconds - fn: a callable to invoke - args: tuple of args to be passed to function - kwargs: keyword arguments to be passed to function + Arguments: + + t: timer interval in milliseconds + fn: a callable to invoke + args: tuple of args to be passed to function + kwargs: keyword arguments to be passed to function """ def __init__(self, t, fn, *args, **kwargs): |