code: func NewProtoConsumerMessage(msg *ConsumerMessage, serializer keyval.Serializer) *ProtoConsumerMessage {
  	return &ProtoConsumerMessage{msg, serializer}
  }
docs: // NewProtoConsumerMessage creates new instance of ProtoConsumerMessage