kafkaconsumermessage

Documentation

Index

• type Message
• type RecordHeader

Types

type Message

type Message struct {
	Headers        []*RecordHeader // only set if kafka is version 0.11+
	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

	Key, Value []byte
	Topic      string
	Partition  int32
	Offset     int64
}

type RecordHeader

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