Versions in this module Expand all Collapse all v1 v1.2.0 Dec 12, 2019 Changes in this version + type Decoder interface + FromBytes func(bytes []byte) (creator.Message, error) + type Encoder interface + Bytes func(m creator.Message) ([]byte, error) + type KafqaParser struct + func (kafqaParser KafqaParser) Bytes(m creator.Message) ([]byte, error) + func (kafqaParser KafqaParser) FromBytes(data []byte) (creator.Message, error) + type Parser interface + func New(cfg config.ProtoParser) Parser + type ProtoParser struct + func (protoParser ProtoParser) Bytes(m creator.Message) ([]byte, error) + func (protoParser ProtoParser) FromBytes(bytes []byte) (creator.Message, error)