data

Documentation

Index

• type Record
  • func (r *Record) RecordKey() interface{}
  • func (r *Record) RecordValue() interface{}
  • func (r *Record) String() string
• type RecordHeaders
  • func (h RecordHeaders) All() []*sarama.RecordHeader
  • func (h RecordHeaders) Read(name []byte) []byte

Types

type Record

type Record struct {
	Key, Value     []byte
	Topic          string
	Partition      int32
	Offset         int64
	Timestamp      time.Time     // only set if kafka is version 0.10+, inner message timestamp
	BlockTimestamp time.Time     // only set if kafka is version 0.10+, outer (compressed) block timestamp
	Headers        RecordHeaders // only set if kafka is version 0.11+
	UUID           uuid.UUID
}

func (*Record) RecordKey

func (r *Record) RecordKey() interface{}

func (*Record) RecordValue

func (r *Record) RecordValue() interface{}

func (*Record) String

func (r *Record) String() string

type RecordHeaders

type RecordHeaders []*sarama.RecordHeader

func (RecordHeaders) All

func (h RecordHeaders) All() []*sarama.RecordHeader

func (RecordHeaders) Read

func (h RecordHeaders) Read(name []byte) []byte