data

Documentation

Index

• type Record
  • func (r *Record) RecordKey() interface{}
  • func (r *Record) RecordValue() interface{}
  • func (r *Record) String() string
• type RecordHeader

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        []*sarama.RecordHeader // 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 RecordHeader

type RecordHeader struct {
	Key   []byte
	Value []byte
}