diff --git a/kafka/util.py b/kafka/util.py index 6ebcc4f95..1e21730c9 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -120,3 +120,9 @@ def wrapper(self, *args, **kwargs): functools.update_wrapper(wrapper, func) return wrapper + +class classproperty: + def __init__(self, f): + self.f = f + def __get__(self, obj, owner): + return self.f(owner)