Encoders¶

ProtobufEncoder¶

class heka.encoders.ProtobufEncoder(hmc=None)[source]¶

StdlibPayloadEncoder¶

class heka.encoders.StdlibPayloadEncoder(hmc=None)[source]¶: If an incoming message does not have a ‘loglevel’ set, we just use a default of logging.INFO