kafka

Documentation

Index

• func Encode(rec Record) ([]byte, error)
• type Record
  • func Decode(raw []byte) (Record, error)
• type Source
  • func NewSource() *Source
  • func (s *Source) Close() error
  • func (s *Source) Open() error
  • func (s *Source) Record() ([]byte, error)

Functions

func Encode

func Encode(rec Record) ([]byte, error)

Types

type Record

type Record struct {
	Key       []byte
	Value     []byte
	Timestamp time.Time
}

func Decode

func Decode(raw []byte) (Record, error)

type Source

type Source struct {
	KafkaHosts []string
	Topics     []string
	Group      string
	// contains filtered or unexported fields
}

func NewSource

func NewSource() *Source

func (*Source) Close

func (s *Source) Close() error

func (*Source) Open

func (s *Source) Open() error

func (*Source) Record

func (s *Source) Record() ([]byte, error)