diff options
| -rw-r--r-- | kafka/protocol/types.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index c95bd6d..22b49a4 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -100,7 +100,7 @@ class Bytes(AbstractType): @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): |