diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index c95bd6d74..22b49a4a9 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -100,7 +100,7 @@ def decode(cls, data): @classmethod def repr(cls, value): - return repr(value[:100] + b'...' if len(value) > 100 else b'') + return repr(value[:100] + b'...' if value is not None and len(value) > 100 else value) class Boolean(AbstractType):