code: func (cm *ProtoConsumerMessage) GetValue(msg proto.Message) error {
  	err := cm.serializer.Unmarshal(cm.ConsumerMessage.GetValue(), msg)
  	if err != nil {
  		return err
  	}
  	return nil
  }
docs: // GetValue returns the value associated with the message.