From 365cae02da59721df77923bb5f5a2d94a84b2e83 Mon Sep 17 00:00:00 2001
From: Taras Voinarovskiy <voyn1991@gmail.com>
Date: Sat, 14 Oct 2017 09:59:09 +0000
Subject: Added limit of 100 bytes for Bytes debug prints

---
 kafka/protocol/types.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py
index da10326..c95bd6d 100644
--- a/kafka/protocol/types.py
+++ b/kafka/protocol/types.py
@@ -98,6 +98,10 @@ class Bytes(AbstractType):
             raise ValueError('Buffer underrun decoding Bytes')
         return value
 
+    @classmethod
+    def repr(cls, value):
+        return repr(value[:100] + b'...' if len(value) > 100 else b'')
+
 
 class Boolean(AbstractType):
     @classmethod
-- 
cgit v1.2.1