Versions in this module Expand all Collapse all v0 v0.8.0 Feb 14, 2018 Changes in this version + func Encode(rec Record) ([]byte, error) + type Record struct + Key []byte + Timestamp time.Time + Value []byte + func Decode(raw []byte) (Record, error) + type Source struct + Group string + KafkaHosts []string + Topics []string + func NewSource() *Source + func (s *Source) Close() error + func (s *Source) Open() error + func (s *Source) Record() ([]byte, error)