debugging consumerFetchSizeTooSmall error dpkp#1

Vungle · Dec 15, 2014 · 12d34ca · 12d34ca
1 parent 658f5ba
commit 12d34ca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka/protocol.py b/kafka/protocol.py
@@ -172,6 +172,7 @@ def _decode_message(cls, data, offset):
 
         elif codec == CODEC_SNAPPY:
             snp = snappy_decode(value)
+            print snp
             for (offset, msg) in KafkaProtocol._decode_message_set_iter(snp):
                 yield (offset, msg)