parser

type Consumer interface {
	Messages() <-chan *sarama.ConsumerMessage
	Errors() <-chan error
	Notifications() <-chan *cluster.Notification
}

type Decoder interface {
	// ValidateSchemas takes in the path(s) to schema files
	// and returns an error if the schemas are invalid. If
	// schemas are not required by the decoder implementation
	// return nil
	ValidateSchemas(schemas string) error

	// Decode takes in a Kafka message value and returns an interface{}
	// which can be read by json.Marshal() and an error
	Decode([]byte) (interface{}, error)
}

type Parser struct {
	// contains filtered or unexported fields
}