def StatusUpdate(msg):
  PrintUpdate(msg)
Compressed messages should pass in bytes_to_read (via message size)
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/tools/appcfg.py/StatusUpdate--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/protocol/message.py/MessageSet.decode