decoder based protobuf Marshal

protobuf_using_decoder_heka

               //ev.Event.Value is []byte array from kakfa
               messageLen := len(ev.Event.Value)
                if messageLen > cap(pack.MsgBytes) {
                    pack.MsgBytes = make([]byte, messageLen)
                }

                copy(pack.MsgBytes, ev.Event.Value)
                                dRunner.InChan() <- pack
                        }

                        ev.Recycle()
                }

        }