Versions in this module Expand all Collapse all v1 v1.0.0 Aug 25, 2018 Changes in this version + type Consumer interface + Errors func() <-chan error + Messages func() <-chan *sarama.ConsumerMessage + Notifications func() <-chan *cluster.Notification + type Decoder interface + Decode func([]byte) (interface{}, error) + ValidateSchemas func(schemas string) error + type Parser struct + func New(consumer Consumer, topic string, schemas string, decoder Decoder, ...) (*Parser, error) + func (p *Parser) Serve() chan struct{}