From 4b60ddd92d5937859c759f339ffdaaa1f22a1f3a Mon Sep 17 00:00:00 2001 From: Deepjyoti Mondal Date: Tue, 23 Apr 2019 00:21:24 +0530 Subject: [PATCH] fixes #103 - kafka-protocol now uses other available versions too apart from v0 Now kafka-protocol uses commands with higher versions too --- kafka/tools/modules.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/tools/modules.py b/kafka/tools/modules.py index f29ad5a..fedb883 100644 --- a/kafka/tools/modules.py +++ b/kafka/tools/modules.py @@ -31,7 +31,7 @@ def check_class(klass, base_class): base_classes = inspect.getmro(klass) if len(base_classes) == 1: return None - if base_classes[1] == base_class: + if base_class in base_classes: return klass